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 2014/02/12 22:32:35 UTC
svn commit: r1567761 [5/8] - in /hive/trunk: metastore/if/
metastore/src/gen/thrift/gen-cpp/
metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/
metastore/src/gen/thrift/gen-php/metastore/
metastore/src/gen/thrift/gen-py/hive_me...
Modified: hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ThriftHiveMetastore.java
URL: http://svn.apache.org/viewvc/hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ThriftHiveMetastore.java?rev=1567761&r1=1567760&r2=1567761&view=diff
==============================================================================
--- hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ThriftHiveMetastore.java (original)
+++ hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ThriftHiveMetastore.java Wed Feb 12 21:32:34 2014
@@ -108,6 +108,8 @@ public class ThriftHiveMetastore {
public boolean drop_partition_by_name_with_environment_context(String db_name, String tbl_name, String part_name, boolean deleteData, EnvironmentContext environment_context) throws NoSuchObjectException, MetaException, org.apache.thrift.TException;
+ public DropPartitionsResult drop_partitions_req(DropPartitionsRequest req) throws NoSuchObjectException, MetaException, org.apache.thrift.TException;
+
public Partition get_partition(String db_name, String tbl_name, List<String> part_vals) throws MetaException, NoSuchObjectException, org.apache.thrift.TException;
public Partition exchange_partition(Map<String,String> partitionSpecs, String source_db, String source_table_name, String dest_db, String dest_table_name) throws MetaException, NoSuchObjectException, InvalidObjectException, InvalidInputException, org.apache.thrift.TException;
@@ -284,6 +286,8 @@ public class ThriftHiveMetastore {
public void drop_partition_by_name_with_environment_context(String db_name, String tbl_name, String part_name, boolean deleteData, EnvironmentContext environment_context, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.drop_partition_by_name_with_environment_context_call> resultHandler) throws org.apache.thrift.TException;
+ public void drop_partitions_req(DropPartitionsRequest req, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.drop_partitions_req_call> resultHandler) throws org.apache.thrift.TException;
+
public void get_partition(String db_name, String tbl_name, List<String> part_vals, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.get_partition_call> resultHandler) throws org.apache.thrift.TException;
public void exchange_partition(Map<String,String> partitionSpecs, String source_db, String source_table_name, String dest_db, String dest_table_name, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.exchange_partition_call> resultHandler) throws org.apache.thrift.TException;
@@ -1483,6 +1487,35 @@ public class ThriftHiveMetastore {
throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "drop_partition_by_name_with_environment_context failed: unknown result");
}
+ public DropPartitionsResult drop_partitions_req(DropPartitionsRequest req) throws NoSuchObjectException, MetaException, org.apache.thrift.TException
+ {
+ send_drop_partitions_req(req);
+ return recv_drop_partitions_req();
+ }
+
+ public void send_drop_partitions_req(DropPartitionsRequest req) throws org.apache.thrift.TException
+ {
+ drop_partitions_req_args args = new drop_partitions_req_args();
+ args.setReq(req);
+ sendBase("drop_partitions_req", args);
+ }
+
+ public DropPartitionsResult recv_drop_partitions_req() throws NoSuchObjectException, MetaException, org.apache.thrift.TException
+ {
+ drop_partitions_req_result result = new drop_partitions_req_result();
+ receiveBase(result, "drop_partitions_req");
+ if (result.isSetSuccess()) {
+ return result.success;
+ }
+ if (result.o1 != null) {
+ throw result.o1;
+ }
+ if (result.o2 != null) {
+ throw result.o2;
+ }
+ throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "drop_partitions_req failed: unknown result");
+ }
+
public Partition get_partition(String db_name, String tbl_name, List<String> part_vals) throws MetaException, NoSuchObjectException, org.apache.thrift.TException
{
send_get_partition(db_name, tbl_name, part_vals);
@@ -4313,6 +4346,38 @@ public class ThriftHiveMetastore {
}
}
+ public void drop_partitions_req(DropPartitionsRequest req, org.apache.thrift.async.AsyncMethodCallback<drop_partitions_req_call> resultHandler) throws org.apache.thrift.TException {
+ checkReady();
+ drop_partitions_req_call method_call = new drop_partitions_req_call(req, resultHandler, this, ___protocolFactory, ___transport);
+ this.___currentMethod = method_call;
+ ___manager.call(method_call);
+ }
+
+ public static class drop_partitions_req_call extends org.apache.thrift.async.TAsyncMethodCall {
+ private DropPartitionsRequest req;
+ public drop_partitions_req_call(DropPartitionsRequest req, org.apache.thrift.async.AsyncMethodCallback<drop_partitions_req_call> 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_partitions_req", org.apache.thrift.protocol.TMessageType.CALL, 0));
+ drop_partitions_req_args args = new drop_partitions_req_args();
+ args.setReq(req);
+ args.write(prot);
+ prot.writeMessageEnd();
+ }
+
+ public DropPartitionsResult getResult() throws NoSuchObjectException, MetaException, org.apache.thrift.TException {
+ if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) {
+ throw new IllegalStateException("Method call not finished!");
+ }
+ org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array());
+ org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport);
+ return (new Client(prot)).recv_drop_partitions_req();
+ }
+ }
+
public void get_partition(String db_name, String tbl_name, List<String> part_vals, org.apache.thrift.async.AsyncMethodCallback<get_partition_call> resultHandler) throws org.apache.thrift.TException {
checkReady();
get_partition_call method_call = new get_partition_call(db_name, tbl_name, part_vals, resultHandler, this, ___protocolFactory, ___transport);
@@ -6263,6 +6328,7 @@ public class ThriftHiveMetastore {
processMap.put("drop_partition_with_environment_context", new drop_partition_with_environment_context());
processMap.put("drop_partition_by_name", new drop_partition_by_name());
processMap.put("drop_partition_by_name_with_environment_context", new drop_partition_by_name_with_environment_context());
+ processMap.put("drop_partitions_req", new drop_partitions_req());
processMap.put("get_partition", new get_partition());
processMap.put("exchange_partition", new exchange_partition());
processMap.put("get_partition_with_auth", new get_partition_with_auth());
@@ -7262,6 +7328,32 @@ public class ThriftHiveMetastore {
}
}
+ public static class drop_partitions_req<I extends Iface> extends org.apache.thrift.ProcessFunction<I, drop_partitions_req_args> {
+ public drop_partitions_req() {
+ super("drop_partitions_req");
+ }
+
+ public drop_partitions_req_args getEmptyArgsInstance() {
+ return new drop_partitions_req_args();
+ }
+
+ protected boolean isOneway() {
+ return false;
+ }
+
+ public drop_partitions_req_result getResult(I iface, drop_partitions_req_args args) throws org.apache.thrift.TException {
+ drop_partitions_req_result result = new drop_partitions_req_result();
+ try {
+ result.success = iface.drop_partitions_req(args.req);
+ } catch (NoSuchObjectException o1) {
+ result.o1 = o1;
+ } catch (MetaException o2) {
+ result.o2 = o2;
+ }
+ return result;
+ }
+ }
+
public static class get_partition<I extends Iface> extends org.apache.thrift.ProcessFunction<I, get_partition_args> {
public get_partition() {
super("get_partition");
@@ -12362,13 +12454,13 @@ public class ThriftHiveMetastore {
case 0: // SUCCESS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list330 = iprot.readListBegin();
- struct.success = new ArrayList<String>(_list330.size);
- for (int _i331 = 0; _i331 < _list330.size; ++_i331)
+ org.apache.thrift.protocol.TList _list354 = iprot.readListBegin();
+ struct.success = new ArrayList<String>(_list354.size);
+ for (int _i355 = 0; _i355 < _list354.size; ++_i355)
{
- String _elem332; // required
- _elem332 = iprot.readString();
- struct.success.add(_elem332);
+ String _elem356; // required
+ _elem356 = iprot.readString();
+ struct.success.add(_elem356);
}
iprot.readListEnd();
}
@@ -12403,9 +12495,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 _iter333 : struct.success)
+ for (String _iter357 : struct.success)
{
- oprot.writeString(_iter333);
+ oprot.writeString(_iter357);
}
oprot.writeListEnd();
}
@@ -12444,9 +12536,9 @@ public class ThriftHiveMetastore {
if (struct.isSetSuccess()) {
{
oprot.writeI32(struct.success.size());
- for (String _iter334 : struct.success)
+ for (String _iter358 : struct.success)
{
- oprot.writeString(_iter334);
+ oprot.writeString(_iter358);
}
}
}
@@ -12461,13 +12553,13 @@ public class ThriftHiveMetastore {
BitSet incoming = iprot.readBitSet(2);
if (incoming.get(0)) {
{
- org.apache.thrift.protocol.TList _list335 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
- struct.success = new ArrayList<String>(_list335.size);
- for (int _i336 = 0; _i336 < _list335.size; ++_i336)
+ org.apache.thrift.protocol.TList _list359 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+ struct.success = new ArrayList<String>(_list359.size);
+ for (int _i360 = 0; _i360 < _list359.size; ++_i360)
{
- String _elem337; // required
- _elem337 = iprot.readString();
- struct.success.add(_elem337);
+ String _elem361; // required
+ _elem361 = iprot.readString();
+ struct.success.add(_elem361);
}
}
struct.setSuccessIsSet(true);
@@ -13124,13 +13216,13 @@ public class ThriftHiveMetastore {
case 0: // SUCCESS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list338 = iprot.readListBegin();
- struct.success = new ArrayList<String>(_list338.size);
- for (int _i339 = 0; _i339 < _list338.size; ++_i339)
+ org.apache.thrift.protocol.TList _list362 = iprot.readListBegin();
+ struct.success = new ArrayList<String>(_list362.size);
+ for (int _i363 = 0; _i363 < _list362.size; ++_i363)
{
- String _elem340; // required
- _elem340 = iprot.readString();
- struct.success.add(_elem340);
+ String _elem364; // required
+ _elem364 = iprot.readString();
+ struct.success.add(_elem364);
}
iprot.readListEnd();
}
@@ -13165,9 +13257,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 _iter341 : struct.success)
+ for (String _iter365 : struct.success)
{
- oprot.writeString(_iter341);
+ oprot.writeString(_iter365);
}
oprot.writeListEnd();
}
@@ -13206,9 +13298,9 @@ public class ThriftHiveMetastore {
if (struct.isSetSuccess()) {
{
oprot.writeI32(struct.success.size());
- for (String _iter342 : struct.success)
+ for (String _iter366 : struct.success)
{
- oprot.writeString(_iter342);
+ oprot.writeString(_iter366);
}
}
}
@@ -13223,13 +13315,13 @@ public class ThriftHiveMetastore {
BitSet incoming = iprot.readBitSet(2);
if (incoming.get(0)) {
{
- org.apache.thrift.protocol.TList _list343 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
- struct.success = new ArrayList<String>(_list343.size);
- for (int _i344 = 0; _i344 < _list343.size; ++_i344)
+ org.apache.thrift.protocol.TList _list367 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+ struct.success = new ArrayList<String>(_list367.size);
+ for (int _i368 = 0; _i368 < _list367.size; ++_i368)
{
- String _elem345; // required
- _elem345 = iprot.readString();
- struct.success.add(_elem345);
+ String _elem369; // required
+ _elem369 = iprot.readString();
+ struct.success.add(_elem369);
}
}
struct.setSuccessIsSet(true);
@@ -17836,16 +17928,16 @@ public class ThriftHiveMetastore {
case 0: // SUCCESS
if (schemeField.type == org.apache.thrift.protocol.TType.MAP) {
{
- org.apache.thrift.protocol.TMap _map346 = iprot.readMapBegin();
- struct.success = new HashMap<String,Type>(2*_map346.size);
- for (int _i347 = 0; _i347 < _map346.size; ++_i347)
+ org.apache.thrift.protocol.TMap _map370 = iprot.readMapBegin();
+ struct.success = new HashMap<String,Type>(2*_map370.size);
+ for (int _i371 = 0; _i371 < _map370.size; ++_i371)
{
- String _key348; // required
- Type _val349; // required
- _key348 = iprot.readString();
- _val349 = new Type();
- _val349.read(iprot);
- struct.success.put(_key348, _val349);
+ String _key372; // required
+ Type _val373; // required
+ _key372 = iprot.readString();
+ _val373 = new Type();
+ _val373.read(iprot);
+ struct.success.put(_key372, _val373);
}
iprot.readMapEnd();
}
@@ -17880,10 +17972,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> _iter350 : struct.success.entrySet())
+ for (Map.Entry<String, Type> _iter374 : struct.success.entrySet())
{
- oprot.writeString(_iter350.getKey());
- _iter350.getValue().write(oprot);
+ oprot.writeString(_iter374.getKey());
+ _iter374.getValue().write(oprot);
}
oprot.writeMapEnd();
}
@@ -17922,10 +18014,10 @@ public class ThriftHiveMetastore {
if (struct.isSetSuccess()) {
{
oprot.writeI32(struct.success.size());
- for (Map.Entry<String, Type> _iter351 : struct.success.entrySet())
+ for (Map.Entry<String, Type> _iter375 : struct.success.entrySet())
{
- oprot.writeString(_iter351.getKey());
- _iter351.getValue().write(oprot);
+ oprot.writeString(_iter375.getKey());
+ _iter375.getValue().write(oprot);
}
}
}
@@ -17940,16 +18032,16 @@ public class ThriftHiveMetastore {
BitSet incoming = iprot.readBitSet(2);
if (incoming.get(0)) {
{
- org.apache.thrift.protocol.TMap _map352 = 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*_map352.size);
- for (int _i353 = 0; _i353 < _map352.size; ++_i353)
+ org.apache.thrift.protocol.TMap _map376 = 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*_map376.size);
+ for (int _i377 = 0; _i377 < _map376.size; ++_i377)
{
- String _key354; // required
- Type _val355; // required
- _key354 = iprot.readString();
- _val355 = new Type();
- _val355.read(iprot);
- struct.success.put(_key354, _val355);
+ String _key378; // required
+ Type _val379; // required
+ _key378 = iprot.readString();
+ _val379 = new Type();
+ _val379.read(iprot);
+ struct.success.put(_key378, _val379);
}
}
struct.setSuccessIsSet(true);
@@ -18984,14 +19076,14 @@ public class ThriftHiveMetastore {
case 0: // SUCCESS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list356 = iprot.readListBegin();
- struct.success = new ArrayList<FieldSchema>(_list356.size);
- for (int _i357 = 0; _i357 < _list356.size; ++_i357)
+ org.apache.thrift.protocol.TList _list380 = iprot.readListBegin();
+ struct.success = new ArrayList<FieldSchema>(_list380.size);
+ for (int _i381 = 0; _i381 < _list380.size; ++_i381)
{
- FieldSchema _elem358; // required
- _elem358 = new FieldSchema();
- _elem358.read(iprot);
- struct.success.add(_elem358);
+ FieldSchema _elem382; // required
+ _elem382 = new FieldSchema();
+ _elem382.read(iprot);
+ struct.success.add(_elem382);
}
iprot.readListEnd();
}
@@ -19044,9 +19136,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 _iter359 : struct.success)
+ for (FieldSchema _iter383 : struct.success)
{
- _iter359.write(oprot);
+ _iter383.write(oprot);
}
oprot.writeListEnd();
}
@@ -19101,9 +19193,9 @@ public class ThriftHiveMetastore {
if (struct.isSetSuccess()) {
{
oprot.writeI32(struct.success.size());
- for (FieldSchema _iter360 : struct.success)
+ for (FieldSchema _iter384 : struct.success)
{
- _iter360.write(oprot);
+ _iter384.write(oprot);
}
}
}
@@ -19124,14 +19216,14 @@ public class ThriftHiveMetastore {
BitSet incoming = iprot.readBitSet(4);
if (incoming.get(0)) {
{
- org.apache.thrift.protocol.TList _list361 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.success = new ArrayList<FieldSchema>(_list361.size);
- for (int _i362 = 0; _i362 < _list361.size; ++_i362)
+ org.apache.thrift.protocol.TList _list385 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.success = new ArrayList<FieldSchema>(_list385.size);
+ for (int _i386 = 0; _i386 < _list385.size; ++_i386)
{
- FieldSchema _elem363; // required
- _elem363 = new FieldSchema();
- _elem363.read(iprot);
- struct.success.add(_elem363);
+ FieldSchema _elem387; // required
+ _elem387 = new FieldSchema();
+ _elem387.read(iprot);
+ struct.success.add(_elem387);
}
}
struct.setSuccessIsSet(true);
@@ -20176,14 +20268,14 @@ public class ThriftHiveMetastore {
case 0: // SUCCESS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list364 = iprot.readListBegin();
- struct.success = new ArrayList<FieldSchema>(_list364.size);
- for (int _i365 = 0; _i365 < _list364.size; ++_i365)
+ org.apache.thrift.protocol.TList _list388 = iprot.readListBegin();
+ struct.success = new ArrayList<FieldSchema>(_list388.size);
+ for (int _i389 = 0; _i389 < _list388.size; ++_i389)
{
- FieldSchema _elem366; // required
- _elem366 = new FieldSchema();
- _elem366.read(iprot);
- struct.success.add(_elem366);
+ FieldSchema _elem390; // required
+ _elem390 = new FieldSchema();
+ _elem390.read(iprot);
+ struct.success.add(_elem390);
}
iprot.readListEnd();
}
@@ -20236,9 +20328,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 _iter367 : struct.success)
+ for (FieldSchema _iter391 : struct.success)
{
- _iter367.write(oprot);
+ _iter391.write(oprot);
}
oprot.writeListEnd();
}
@@ -20293,9 +20385,9 @@ public class ThriftHiveMetastore {
if (struct.isSetSuccess()) {
{
oprot.writeI32(struct.success.size());
- for (FieldSchema _iter368 : struct.success)
+ for (FieldSchema _iter392 : struct.success)
{
- _iter368.write(oprot);
+ _iter392.write(oprot);
}
}
}
@@ -20316,14 +20408,14 @@ public class ThriftHiveMetastore {
BitSet incoming = iprot.readBitSet(4);
if (incoming.get(0)) {
{
- org.apache.thrift.protocol.TList _list369 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.success = new ArrayList<FieldSchema>(_list369.size);
- for (int _i370 = 0; _i370 < _list369.size; ++_i370)
+ org.apache.thrift.protocol.TList _list393 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.success = new ArrayList<FieldSchema>(_list393.size);
+ for (int _i394 = 0; _i394 < _list393.size; ++_i394)
{
- FieldSchema _elem371; // required
- _elem371 = new FieldSchema();
- _elem371.read(iprot);
- struct.success.add(_elem371);
+ FieldSchema _elem395; // required
+ _elem395 = new FieldSchema();
+ _elem395.read(iprot);
+ struct.success.add(_elem395);
}
}
struct.setSuccessIsSet(true);
@@ -25566,13 +25658,13 @@ public class ThriftHiveMetastore {
case 0: // SUCCESS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list372 = iprot.readListBegin();
- struct.success = new ArrayList<String>(_list372.size);
- for (int _i373 = 0; _i373 < _list372.size; ++_i373)
+ org.apache.thrift.protocol.TList _list396 = iprot.readListBegin();
+ struct.success = new ArrayList<String>(_list396.size);
+ for (int _i397 = 0; _i397 < _list396.size; ++_i397)
{
- String _elem374; // required
- _elem374 = iprot.readString();
- struct.success.add(_elem374);
+ String _elem398; // required
+ _elem398 = iprot.readString();
+ struct.success.add(_elem398);
}
iprot.readListEnd();
}
@@ -25607,9 +25699,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 _iter375 : struct.success)
+ for (String _iter399 : struct.success)
{
- oprot.writeString(_iter375);
+ oprot.writeString(_iter399);
}
oprot.writeListEnd();
}
@@ -25648,9 +25740,9 @@ public class ThriftHiveMetastore {
if (struct.isSetSuccess()) {
{
oprot.writeI32(struct.success.size());
- for (String _iter376 : struct.success)
+ for (String _iter400 : struct.success)
{
- oprot.writeString(_iter376);
+ oprot.writeString(_iter400);
}
}
}
@@ -25665,13 +25757,13 @@ public class ThriftHiveMetastore {
BitSet incoming = iprot.readBitSet(2);
if (incoming.get(0)) {
{
- org.apache.thrift.protocol.TList _list377 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
- struct.success = new ArrayList<String>(_list377.size);
- for (int _i378 = 0; _i378 < _list377.size; ++_i378)
+ org.apache.thrift.protocol.TList _list401 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+ struct.success = new ArrayList<String>(_list401.size);
+ for (int _i402 = 0; _i402 < _list401.size; ++_i402)
{
- String _elem379; // required
- _elem379 = iprot.readString();
- struct.success.add(_elem379);
+ String _elem403; // required
+ _elem403 = iprot.readString();
+ struct.success.add(_elem403);
}
}
struct.setSuccessIsSet(true);
@@ -26440,13 +26532,13 @@ public class ThriftHiveMetastore {
case 0: // SUCCESS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list380 = iprot.readListBegin();
- struct.success = new ArrayList<String>(_list380.size);
- for (int _i381 = 0; _i381 < _list380.size; ++_i381)
+ org.apache.thrift.protocol.TList _list404 = iprot.readListBegin();
+ struct.success = new ArrayList<String>(_list404.size);
+ for (int _i405 = 0; _i405 < _list404.size; ++_i405)
{
- String _elem382; // required
- _elem382 = iprot.readString();
- struct.success.add(_elem382);
+ String _elem406; // required
+ _elem406 = iprot.readString();
+ struct.success.add(_elem406);
}
iprot.readListEnd();
}
@@ -26481,9 +26573,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 _iter383 : struct.success)
+ for (String _iter407 : struct.success)
{
- oprot.writeString(_iter383);
+ oprot.writeString(_iter407);
}
oprot.writeListEnd();
}
@@ -26522,9 +26614,9 @@ public class ThriftHiveMetastore {
if (struct.isSetSuccess()) {
{
oprot.writeI32(struct.success.size());
- for (String _iter384 : struct.success)
+ for (String _iter408 : struct.success)
{
- oprot.writeString(_iter384);
+ oprot.writeString(_iter408);
}
}
}
@@ -26539,13 +26631,13 @@ public class ThriftHiveMetastore {
BitSet incoming = iprot.readBitSet(2);
if (incoming.get(0)) {
{
- org.apache.thrift.protocol.TList _list385 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
- struct.success = new ArrayList<String>(_list385.size);
- for (int _i386 = 0; _i386 < _list385.size; ++_i386)
+ org.apache.thrift.protocol.TList _list409 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+ struct.success = new ArrayList<String>(_list409.size);
+ for (int _i410 = 0; _i410 < _list409.size; ++_i410)
{
- String _elem387; // required
- _elem387 = iprot.readString();
- struct.success.add(_elem387);
+ String _elem411; // required
+ _elem411 = iprot.readString();
+ struct.success.add(_elem411);
}
}
struct.setSuccessIsSet(true);
@@ -28001,13 +28093,13 @@ public class ThriftHiveMetastore {
case 2: // TBL_NAMES
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list388 = iprot.readListBegin();
- struct.tbl_names = new ArrayList<String>(_list388.size);
- for (int _i389 = 0; _i389 < _list388.size; ++_i389)
+ org.apache.thrift.protocol.TList _list412 = iprot.readListBegin();
+ struct.tbl_names = new ArrayList<String>(_list412.size);
+ for (int _i413 = 0; _i413 < _list412.size; ++_i413)
{
- String _elem390; // required
- _elem390 = iprot.readString();
- struct.tbl_names.add(_elem390);
+ String _elem414; // required
+ _elem414 = iprot.readString();
+ struct.tbl_names.add(_elem414);
}
iprot.readListEnd();
}
@@ -28038,9 +28130,9 @@ public class ThriftHiveMetastore {
oprot.writeFieldBegin(TBL_NAMES_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, struct.tbl_names.size()));
- for (String _iter391 : struct.tbl_names)
+ for (String _iter415 : struct.tbl_names)
{
- oprot.writeString(_iter391);
+ oprot.writeString(_iter415);
}
oprot.writeListEnd();
}
@@ -28077,9 +28169,9 @@ public class ThriftHiveMetastore {
if (struct.isSetTbl_names()) {
{
oprot.writeI32(struct.tbl_names.size());
- for (String _iter392 : struct.tbl_names)
+ for (String _iter416 : struct.tbl_names)
{
- oprot.writeString(_iter392);
+ oprot.writeString(_iter416);
}
}
}
@@ -28095,13 +28187,13 @@ public class ThriftHiveMetastore {
}
if (incoming.get(1)) {
{
- org.apache.thrift.protocol.TList _list393 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
- struct.tbl_names = new ArrayList<String>(_list393.size);
- for (int _i394 = 0; _i394 < _list393.size; ++_i394)
+ org.apache.thrift.protocol.TList _list417 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+ struct.tbl_names = new ArrayList<String>(_list417.size);
+ for (int _i418 = 0; _i418 < _list417.size; ++_i418)
{
- String _elem395; // required
- _elem395 = iprot.readString();
- struct.tbl_names.add(_elem395);
+ String _elem419; // required
+ _elem419 = iprot.readString();
+ struct.tbl_names.add(_elem419);
}
}
struct.setTbl_namesIsSet(true);
@@ -28669,14 +28761,14 @@ public class ThriftHiveMetastore {
case 0: // SUCCESS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list396 = iprot.readListBegin();
- struct.success = new ArrayList<Table>(_list396.size);
- for (int _i397 = 0; _i397 < _list396.size; ++_i397)
+ org.apache.thrift.protocol.TList _list420 = iprot.readListBegin();
+ struct.success = new ArrayList<Table>(_list420.size);
+ for (int _i421 = 0; _i421 < _list420.size; ++_i421)
{
- Table _elem398; // required
- _elem398 = new Table();
- _elem398.read(iprot);
- struct.success.add(_elem398);
+ Table _elem422; // required
+ _elem422 = new Table();
+ _elem422.read(iprot);
+ struct.success.add(_elem422);
}
iprot.readListEnd();
}
@@ -28729,9 +28821,9 @@ public class ThriftHiveMetastore {
oprot.writeFieldBegin(SUCCESS_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.success.size()));
- for (Table _iter399 : struct.success)
+ for (Table _iter423 : struct.success)
{
- _iter399.write(oprot);
+ _iter423.write(oprot);
}
oprot.writeListEnd();
}
@@ -28786,9 +28878,9 @@ public class ThriftHiveMetastore {
if (struct.isSetSuccess()) {
{
oprot.writeI32(struct.success.size());
- for (Table _iter400 : struct.success)
+ for (Table _iter424 : struct.success)
{
- _iter400.write(oprot);
+ _iter424.write(oprot);
}
}
}
@@ -28809,14 +28901,14 @@ public class ThriftHiveMetastore {
BitSet incoming = iprot.readBitSet(4);
if (incoming.get(0)) {
{
- org.apache.thrift.protocol.TList _list401 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.success = new ArrayList<Table>(_list401.size);
- for (int _i402 = 0; _i402 < _list401.size; ++_i402)
+ org.apache.thrift.protocol.TList _list425 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.success = new ArrayList<Table>(_list425.size);
+ for (int _i426 = 0; _i426 < _list425.size; ++_i426)
{
- Table _elem403; // required
- _elem403 = new Table();
- _elem403.read(iprot);
- struct.success.add(_elem403);
+ Table _elem427; // required
+ _elem427 = new Table();
+ _elem427.read(iprot);
+ struct.success.add(_elem427);
}
}
struct.setSuccessIsSet(true);
@@ -29965,13 +30057,13 @@ public class ThriftHiveMetastore {
case 0: // SUCCESS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list404 = iprot.readListBegin();
- struct.success = new ArrayList<String>(_list404.size);
- for (int _i405 = 0; _i405 < _list404.size; ++_i405)
+ org.apache.thrift.protocol.TList _list428 = iprot.readListBegin();
+ struct.success = new ArrayList<String>(_list428.size);
+ for (int _i429 = 0; _i429 < _list428.size; ++_i429)
{
- String _elem406; // required
- _elem406 = iprot.readString();
- struct.success.add(_elem406);
+ String _elem430; // required
+ _elem430 = iprot.readString();
+ struct.success.add(_elem430);
}
iprot.readListEnd();
}
@@ -30024,9 +30116,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 _iter407 : struct.success)
+ for (String _iter431 : struct.success)
{
- oprot.writeString(_iter407);
+ oprot.writeString(_iter431);
}
oprot.writeListEnd();
}
@@ -30081,9 +30173,9 @@ public class ThriftHiveMetastore {
if (struct.isSetSuccess()) {
{
oprot.writeI32(struct.success.size());
- for (String _iter408 : struct.success)
+ for (String _iter432 : struct.success)
{
- oprot.writeString(_iter408);
+ oprot.writeString(_iter432);
}
}
}
@@ -30104,13 +30196,13 @@ public class ThriftHiveMetastore {
BitSet incoming = iprot.readBitSet(4);
if (incoming.get(0)) {
{
- org.apache.thrift.protocol.TList _list409 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
- struct.success = new ArrayList<String>(_list409.size);
- for (int _i410 = 0; _i410 < _list409.size; ++_i410)
+ org.apache.thrift.protocol.TList _list433 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+ struct.success = new ArrayList<String>(_list433.size);
+ for (int _i434 = 0; _i434 < _list433.size; ++_i434)
{
- String _elem411; // required
- _elem411 = iprot.readString();
- struct.success.add(_elem411);
+ String _elem435; // required
+ _elem435 = iprot.readString();
+ struct.success.add(_elem435);
}
}
struct.setSuccessIsSet(true);
@@ -34830,14 +34922,14 @@ public class ThriftHiveMetastore {
case 1: // NEW_PARTS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list412 = iprot.readListBegin();
- struct.new_parts = new ArrayList<Partition>(_list412.size);
- for (int _i413 = 0; _i413 < _list412.size; ++_i413)
+ org.apache.thrift.protocol.TList _list436 = iprot.readListBegin();
+ struct.new_parts = new ArrayList<Partition>(_list436.size);
+ for (int _i437 = 0; _i437 < _list436.size; ++_i437)
{
- Partition _elem414; // required
- _elem414 = new Partition();
- _elem414.read(iprot);
- struct.new_parts.add(_elem414);
+ Partition _elem438; // required
+ _elem438 = new Partition();
+ _elem438.read(iprot);
+ struct.new_parts.add(_elem438);
}
iprot.readListEnd();
}
@@ -34863,9 +34955,9 @@ public class ThriftHiveMetastore {
oprot.writeFieldBegin(NEW_PARTS_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.new_parts.size()));
- for (Partition _iter415 : struct.new_parts)
+ for (Partition _iter439 : struct.new_parts)
{
- _iter415.write(oprot);
+ _iter439.write(oprot);
}
oprot.writeListEnd();
}
@@ -34896,9 +34988,9 @@ public class ThriftHiveMetastore {
if (struct.isSetNew_parts()) {
{
oprot.writeI32(struct.new_parts.size());
- for (Partition _iter416 : struct.new_parts)
+ for (Partition _iter440 : struct.new_parts)
{
- _iter416.write(oprot);
+ _iter440.write(oprot);
}
}
}
@@ -34910,14 +35002,14 @@ public class ThriftHiveMetastore {
BitSet incoming = iprot.readBitSet(1);
if (incoming.get(0)) {
{
- org.apache.thrift.protocol.TList _list417 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.new_parts = new ArrayList<Partition>(_list417.size);
- for (int _i418 = 0; _i418 < _list417.size; ++_i418)
+ org.apache.thrift.protocol.TList _list441 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.new_parts = new ArrayList<Partition>(_list441.size);
+ for (int _i442 = 0; _i442 < _list441.size; ++_i442)
{
- Partition _elem419; // required
- _elem419 = new Partition();
- _elem419.read(iprot);
- struct.new_parts.add(_elem419);
+ Partition _elem443; // required
+ _elem443 = new Partition();
+ _elem443.read(iprot);
+ struct.new_parts.add(_elem443);
}
}
struct.setNew_partsIsSet(true);
@@ -36096,13 +36188,13 @@ public class ThriftHiveMetastore {
case 3: // PART_VALS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list420 = iprot.readListBegin();
- struct.part_vals = new ArrayList<String>(_list420.size);
- for (int _i421 = 0; _i421 < _list420.size; ++_i421)
+ org.apache.thrift.protocol.TList _list444 = iprot.readListBegin();
+ struct.part_vals = new ArrayList<String>(_list444.size);
+ for (int _i445 = 0; _i445 < _list444.size; ++_i445)
{
- String _elem422; // required
- _elem422 = iprot.readString();
- struct.part_vals.add(_elem422);
+ String _elem446; // required
+ _elem446 = iprot.readString();
+ struct.part_vals.add(_elem446);
}
iprot.readListEnd();
}
@@ -36138,9 +36230,9 @@ public class ThriftHiveMetastore {
oprot.writeFieldBegin(PART_VALS_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, struct.part_vals.size()));
- for (String _iter423 : struct.part_vals)
+ for (String _iter447 : struct.part_vals)
{
- oprot.writeString(_iter423);
+ oprot.writeString(_iter447);
}
oprot.writeListEnd();
}
@@ -36183,9 +36275,9 @@ public class ThriftHiveMetastore {
if (struct.isSetPart_vals()) {
{
oprot.writeI32(struct.part_vals.size());
- for (String _iter424 : struct.part_vals)
+ for (String _iter448 : struct.part_vals)
{
- oprot.writeString(_iter424);
+ oprot.writeString(_iter448);
}
}
}
@@ -36205,13 +36297,13 @@ public class ThriftHiveMetastore {
}
if (incoming.get(2)) {
{
- org.apache.thrift.protocol.TList _list425 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
- struct.part_vals = new ArrayList<String>(_list425.size);
- for (int _i426 = 0; _i426 < _list425.size; ++_i426)
+ org.apache.thrift.protocol.TList _list449 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+ struct.part_vals = new ArrayList<String>(_list449.size);
+ for (int _i450 = 0; _i450 < _list449.size; ++_i450)
{
- String _elem427; // required
- _elem427 = iprot.readString();
- struct.part_vals.add(_elem427);
+ String _elem451; // required
+ _elem451 = iprot.readString();
+ struct.part_vals.add(_elem451);
}
}
struct.setPart_valsIsSet(true);
@@ -38523,13 +38615,13 @@ public class ThriftHiveMetastore {
case 3: // PART_VALS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list428 = iprot.readListBegin();
- struct.part_vals = new ArrayList<String>(_list428.size);
- for (int _i429 = 0; _i429 < _list428.size; ++_i429)
+ org.apache.thrift.protocol.TList _list452 = iprot.readListBegin();
+ struct.part_vals = new ArrayList<String>(_list452.size);
+ for (int _i453 = 0; _i453 < _list452.size; ++_i453)
{
- String _elem430; // required
- _elem430 = iprot.readString();
- struct.part_vals.add(_elem430);
+ String _elem454; // required
+ _elem454 = iprot.readString();
+ struct.part_vals.add(_elem454);
}
iprot.readListEnd();
}
@@ -38574,9 +38666,9 @@ public class ThriftHiveMetastore {
oprot.writeFieldBegin(PART_VALS_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, struct.part_vals.size()));
- for (String _iter431 : struct.part_vals)
+ for (String _iter455 : struct.part_vals)
{
- oprot.writeString(_iter431);
+ oprot.writeString(_iter455);
}
oprot.writeListEnd();
}
@@ -38627,9 +38719,9 @@ public class ThriftHiveMetastore {
if (struct.isSetPart_vals()) {
{
oprot.writeI32(struct.part_vals.size());
- for (String _iter432 : struct.part_vals)
+ for (String _iter456 : struct.part_vals)
{
- oprot.writeString(_iter432);
+ oprot.writeString(_iter456);
}
}
}
@@ -38652,13 +38744,13 @@ public class ThriftHiveMetastore {
}
if (incoming.get(2)) {
{
- org.apache.thrift.protocol.TList _list433 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
- struct.part_vals = new ArrayList<String>(_list433.size);
- for (int _i434 = 0; _i434 < _list433.size; ++_i434)
+ org.apache.thrift.protocol.TList _list457 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+ struct.part_vals = new ArrayList<String>(_list457.size);
+ for (int _i458 = 0; _i458 < _list457.size; ++_i458)
{
- String _elem435; // required
- _elem435 = iprot.readString();
- struct.part_vals.add(_elem435);
+ String _elem459; // required
+ _elem459 = iprot.readString();
+ struct.part_vals.add(_elem459);
}
}
struct.setPart_valsIsSet(true);
@@ -42531,13 +42623,13 @@ public class ThriftHiveMetastore {
case 3: // PART_VALS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list436 = iprot.readListBegin();
- struct.part_vals = new ArrayList<String>(_list436.size);
- for (int _i437 = 0; _i437 < _list436.size; ++_i437)
+ org.apache.thrift.protocol.TList _list460 = iprot.readListBegin();
+ struct.part_vals = new ArrayList<String>(_list460.size);
+ for (int _i461 = 0; _i461 < _list460.size; ++_i461)
{
- String _elem438; // required
- _elem438 = iprot.readString();
- struct.part_vals.add(_elem438);
+ String _elem462; // required
+ _elem462 = iprot.readString();
+ struct.part_vals.add(_elem462);
}
iprot.readListEnd();
}
@@ -42581,9 +42673,9 @@ public class ThriftHiveMetastore {
oprot.writeFieldBegin(PART_VALS_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, struct.part_vals.size()));
- for (String _iter439 : struct.part_vals)
+ for (String _iter463 : struct.part_vals)
{
- oprot.writeString(_iter439);
+ oprot.writeString(_iter463);
}
oprot.writeListEnd();
}
@@ -42632,9 +42724,9 @@ public class ThriftHiveMetastore {
if (struct.isSetPart_vals()) {
{
oprot.writeI32(struct.part_vals.size());
- for (String _iter440 : struct.part_vals)
+ for (String _iter464 : struct.part_vals)
{
- oprot.writeString(_iter440);
+ oprot.writeString(_iter464);
}
}
}
@@ -42657,13 +42749,13 @@ public class ThriftHiveMetastore {
}
if (incoming.get(2)) {
{
- org.apache.thrift.protocol.TList _list441 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
- struct.part_vals = new ArrayList<String>(_list441.size);
- for (int _i442 = 0; _i442 < _list441.size; ++_i442)
+ org.apache.thrift.protocol.TList _list465 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+ struct.part_vals = new ArrayList<String>(_list465.size);
+ for (int _i466 = 0; _i466 < _list465.size; ++_i466)
{
- String _elem443; // required
- _elem443 = iprot.readString();
- struct.part_vals.add(_elem443);
+ String _elem467; // required
+ _elem467 = iprot.readString();
+ struct.part_vals.add(_elem467);
}
}
struct.setPart_valsIsSet(true);
@@ -43905,13 +43997,13 @@ public class ThriftHiveMetastore {
case 3: // PART_VALS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list444 = iprot.readListBegin();
- struct.part_vals = new ArrayList<String>(_list444.size);
- for (int _i445 = 0; _i445 < _list444.size; ++_i445)
+ org.apache.thrift.protocol.TList _list468 = iprot.readListBegin();
+ struct.part_vals = new ArrayList<String>(_list468.size);
+ for (int _i469 = 0; _i469 < _list468.size; ++_i469)
{
- String _elem446; // required
- _elem446 = iprot.readString();
- struct.part_vals.add(_elem446);
+ String _elem470; // required
+ _elem470 = iprot.readString();
+ struct.part_vals.add(_elem470);
}
iprot.readListEnd();
}
@@ -43964,9 +44056,9 @@ public class ThriftHiveMetastore {
oprot.writeFieldBegin(PART_VALS_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, struct.part_vals.size()));
- for (String _iter447 : struct.part_vals)
+ for (String _iter471 : struct.part_vals)
{
- oprot.writeString(_iter447);
+ oprot.writeString(_iter471);
}
oprot.writeListEnd();
}
@@ -44023,9 +44115,9 @@ public class ThriftHiveMetastore {
if (struct.isSetPart_vals()) {
{
oprot.writeI32(struct.part_vals.size());
- for (String _iter448 : struct.part_vals)
+ for (String _iter472 : struct.part_vals)
{
- oprot.writeString(_iter448);
+ oprot.writeString(_iter472);
}
}
}
@@ -44051,13 +44143,13 @@ public class ThriftHiveMetastore {
}
if (incoming.get(2)) {
{
- org.apache.thrift.protocol.TList _list449 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
- struct.part_vals = new ArrayList<String>(_list449.size);
- for (int _i450 = 0; _i450 < _list449.size; ++_i450)
+ org.apache.thrift.protocol.TList _list473 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+ struct.part_vals = new ArrayList<String>(_list473.size);
+ for (int _i474 = 0; _i474 < _list473.size; ++_i474)
{
- String _elem451; // required
- _elem451 = iprot.readString();
- struct.part_vals.add(_elem451);
+ String _elem475; // required
+ _elem475 = iprot.readString();
+ struct.part_vals.add(_elem475);
}
}
struct.setPart_valsIsSet(true);
@@ -46592,89 +46684,1022 @@ public class ThriftHiveMetastore {
}
}
- private static class drop_partition_by_name_with_environment_context_argsTupleScheme extends TupleScheme<drop_partition_by_name_with_environment_context_args> {
+ private static class drop_partition_by_name_with_environment_context_argsTupleScheme extends TupleScheme<drop_partition_by_name_with_environment_context_args> {
+
+ @Override
+ public void write(org.apache.thrift.protocol.TProtocol prot, drop_partition_by_name_with_environment_context_args struct) throws org.apache.thrift.TException {
+ TTupleProtocol oprot = (TTupleProtocol) prot;
+ BitSet optionals = new BitSet();
+ if (struct.isSetDb_name()) {
+ optionals.set(0);
+ }
+ if (struct.isSetTbl_name()) {
+ optionals.set(1);
+ }
+ if (struct.isSetPart_name()) {
+ optionals.set(2);
+ }
+ if (struct.isSetDeleteData()) {
+ optionals.set(3);
+ }
+ if (struct.isSetEnvironment_context()) {
+ optionals.set(4);
+ }
+ oprot.writeBitSet(optionals, 5);
+ if (struct.isSetDb_name()) {
+ oprot.writeString(struct.db_name);
+ }
+ if (struct.isSetTbl_name()) {
+ oprot.writeString(struct.tbl_name);
+ }
+ if (struct.isSetPart_name()) {
+ oprot.writeString(struct.part_name);
+ }
+ if (struct.isSetDeleteData()) {
+ oprot.writeBool(struct.deleteData);
+ }
+ if (struct.isSetEnvironment_context()) {
+ struct.environment_context.write(oprot);
+ }
+ }
+
+ @Override
+ public void read(org.apache.thrift.protocol.TProtocol prot, drop_partition_by_name_with_environment_context_args struct) throws org.apache.thrift.TException {
+ TTupleProtocol iprot = (TTupleProtocol) prot;
+ BitSet incoming = iprot.readBitSet(5);
+ if (incoming.get(0)) {
+ struct.db_name = iprot.readString();
+ struct.setDb_nameIsSet(true);
+ }
+ if (incoming.get(1)) {
+ struct.tbl_name = iprot.readString();
+ struct.setTbl_nameIsSet(true);
+ }
+ if (incoming.get(2)) {
+ struct.part_name = iprot.readString();
+ struct.setPart_nameIsSet(true);
+ }
+ if (incoming.get(3)) {
+ struct.deleteData = iprot.readBool();
+ struct.setDeleteDataIsSet(true);
+ }
+ if (incoming.get(4)) {
+ struct.environment_context = new EnvironmentContext();
+ struct.environment_context.read(iprot);
+ struct.setEnvironment_contextIsSet(true);
+ }
+ }
+ }
+
+ }
+
+ public static class drop_partition_by_name_with_environment_context_result implements org.apache.thrift.TBase<drop_partition_by_name_with_environment_context_result, drop_partition_by_name_with_environment_context_result._Fields>, java.io.Serializable, Cloneable {
+ private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("drop_partition_by_name_with_environment_context_result");
+
+ private static final org.apache.thrift.protocol.TField SUCCESS_FIELD_DESC = new org.apache.thrift.protocol.TField("success", org.apache.thrift.protocol.TType.BOOL, (short)0);
+ 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 O2_FIELD_DESC = new org.apache.thrift.protocol.TField("o2", 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_partition_by_name_with_environment_context_resultStandardSchemeFactory());
+ schemes.put(TupleScheme.class, new drop_partition_by_name_with_environment_context_resultTupleSchemeFactory());
+ }
+
+ private boolean success; // required
+ private NoSuchObjectException o1; // required
+ private MetaException o2; // 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 {
+ SUCCESS((short)0, "success"),
+ O1((short)1, "o1"),
+ O2((short)2, "o2");
+
+ 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 0: // SUCCESS
+ return SUCCESS;
+ case 1: // O1
+ return O1;
+ case 2: // O2
+ return O2;
+ 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
+ private static final int __SUCCESS_ISSET_ID = 0;
+ private byte __isset_bitfield = 0;
+ 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.SUCCESS, new org.apache.thrift.meta_data.FieldMetaData("success", org.apache.thrift.TFieldRequirementType.DEFAULT,
+ new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.BOOL)));
+ 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.O2, new org.apache.thrift.meta_data.FieldMetaData("o2", 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_partition_by_name_with_environment_context_result.class, metaDataMap);
+ }
+
+ public drop_partition_by_name_with_environment_context_result() {
+ }
+
+ public drop_partition_by_name_with_environment_context_result(
+ boolean success,
+ NoSuchObjectException o1,
+ MetaException o2)
+ {
+ this();
+ this.success = success;
+ setSuccessIsSet(true);
+ this.o1 = o1;
+ this.o2 = o2;
+ }
+
+ /**
+ * Performs a deep copy on <i>other</i>.
+ */
+ public drop_partition_by_name_with_environment_context_result(drop_partition_by_name_with_environment_context_result other) {
+ __isset_bitfield = other.__isset_bitfield;
+ this.success = other.success;
+ if (other.isSetO1()) {
+ this.o1 = new NoSuchObjectException(other.o1);
+ }
+ if (other.isSetO2()) {
+ this.o2 = new MetaException(other.o2);
+ }
+ }
+
+ public drop_partition_by_name_with_environment_context_result deepCopy() {
+ return new drop_partition_by_name_with_environment_context_result(this);
+ }
+
+ @Override
+ public void clear() {
+ setSuccessIsSet(false);
+ this.success = false;
+ this.o1 = null;
+ this.o2 = null;
+ }
+
+ public boolean isSuccess() {
+ return this.success;
+ }
+
+ public void setSuccess(boolean success) {
+ this.success = success;
+ setSuccessIsSet(true);
+ }
+
+ public void unsetSuccess() {
+ __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __SUCCESS_ISSET_ID);
+ }
+
+ /** Returns true if field success is set (has been assigned a value) and false otherwise */
+ public boolean isSetSuccess() {
+ return EncodingUtils.testBit(__isset_bitfield, __SUCCESS_ISSET_ID);
+ }
+
+ public void setSuccessIsSet(boolean value) {
+ __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __SUCCESS_ISSET_ID, value);
+ }
+
+ 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 getO2() {
+ return this.o2;
+ }
+
+ public void setO2(MetaException o2) {
+ this.o2 = o2;
+ }
+
+ public void unsetO2() {
+ this.o2 = null;
+ }
+
+ /** Returns true if field o2 is set (has been assigned a value) and false otherwise */
+ public boolean isSetO2() {
+ return this.o2 != null;
+ }
+
+ public void setO2IsSet(boolean value) {
+ if (!value) {
+ this.o2 = null;
+ }
+ }
+
+ public void setFieldValue(_Fields field, Object value) {
+ switch (field) {
+ case SUCCESS:
+ if (value == null) {
+ unsetSuccess();
+ } else {
+ setSuccess((Boolean)value);
+ }
+ break;
+
+ case O1:
+ if (value == null) {
+ unsetO1();
+ } else {
+ setO1((NoSuchObjectException)value);
+ }
+ break;
+
+ case O2:
+ if (value == null) {
+ unsetO2();
+ } else {
+ setO2((MetaException)value);
+ }
+ break;
+
+ }
+ }
+
+ public Object getFieldValue(_Fields field) {
+ switch (field) {
+ case SUCCESS:
+ return Boolean.valueOf(isSuccess());
+
+ case O1:
+ return getO1();
+
+ case O2:
+ return getO2();
+
+ }
+ 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 SUCCESS:
+ return isSetSuccess();
+ case O1:
+ return isSetO1();
+ case O2:
+ return isSetO2();
+ }
+ throw new IllegalStateException();
+ }
+
+ @Override
+ public boolean equals(Object that) {
+ if (that == null)
+ return false;
+ if (that instanceof drop_partition_by_name_with_environment_context_result)
+ return this.equals((drop_partition_by_name_with_environment_context_result)that);
+ return false;
+ }
+
+ public boolean equals(drop_partition_by_name_with_environment_context_result that) {
+ if (that == null)
+ return false;
+
+ boolean this_present_success = true;
+ boolean that_present_success = true;
+ if (this_present_success || that_present_success) {
+ if (!(this_present_success && that_present_success))
+ return false;
+ if (this.success != that.success)
+ 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_o2 = true && this.isSetO2();
+ boolean that_present_o2 = true && that.isSetO2();
+ if (this_present_o2 || that_present_o2) {
+ if (!(this_present_o2 && that_present_o2))
+ return false;
+ if (!this.o2.equals(that.o2))
+ return false;
+ }
+
+ return true;
+ }
+
+ @Override
+ public int hashCode() {
+ HashCodeBuilder builder = new HashCodeBuilder();
+
+ boolean present_success = true;
+ builder.append(present_success);
+ if (present_success)
+ builder.append(success);
+
+ boolean present_o1 = true && (isSetO1());
+ builder.append(present_o1);
+ if (present_o1)
+ builder.append(o1);
+
+ boolean present_o2 = true && (isSetO2());
+ builder.append(present_o2);
+ if (present_o2)
+ builder.append(o2);
+
+ return builder.toHashCode();
+ }
+
+ public int compareTo(drop_partition_by_name_with_environment_context_result other) {
+ if (!getClass().equals(other.getClass())) {
+ return getClass().getName().compareTo(other.getClass().getName());
+ }
+
+ int lastComparison = 0;
+ drop_partition_by_name_with_environment_context_result typedOther = (drop_partition_by_name_with_environment_context_result)other;
+
+ lastComparison = Boolean.valueOf(isSetSuccess()).compareTo(typedOther.isSetSuccess());
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ if (isSetSuccess()) {
+ lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.success, typedOther.success);
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ }
+ lastComparison = Boolean.valueOf(isSetO1()).compareTo(typedOther.isSetO1());
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ if (isSetO1()) {
+ lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.o1, typedOther.o1);
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ }
+ lastComparison = Boolean.valueOf(isSetO2()).compareTo(typedOther.isSetO2());
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ if (isSetO2()) {
+ lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.o2, typedOther.o2);
+ 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_partition_by_name_with_environment_context_result(");
+ boolean first = true;
+
+ sb.append("success:");
+ sb.append(this.success);
+ first = false;
+ if (!first) sb.append(", ");
+ sb.append("o1:");
+ if (this.o1 == null) {
+ sb.append("null");
+ } else {
+ sb.append(this.o1);
+ }
+ first = false;
+ if (!first) sb.append(", ");
+ sb.append("o2:");
+ if (this.o2 == null) {
+ sb.append("null");
+ } else {
+ sb.append(this.o2);
+ }
+ 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 {
+ // it doesn't seem like you should have to do this, but java serialization is wacky, and doesn't call the default constructor.
+ __isset_bitfield = 0;
+ 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_partition_by_name_with_environment_context_resultStandardSchemeFactory implements SchemeFactory {
+ public drop_partition_by_name_with_environment_context_resultStandardScheme getScheme() {
+ return new drop_partition_by_name_with_environment_context_resultStandardScheme();
+ }
+ }
+
+ private static class drop_partition_by_name_with_environment_context_resultStandardScheme extends StandardScheme<drop_partition_by_name_with_environment_context_result> {
+
+ public void read(org.apache.thrift.protocol.TProtocol iprot, drop_partition_by_name_with_environment_context_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 0: // SUCCESS
+ if (schemeField.type == org.apache.thrift.protocol.TType.BOOL) {
+ struct.success = iprot.readBool();
+ struct.setSuccessIsSet(true);
+ } else {
+ org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+ }
+ break;
+ 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: // O2
+ if (schemeField.type == org.apache.thrift.protocol.TType.STRUCT) {
+ struct.o2 = new MetaException();
+ struct.o2.read(iprot);
+ struct.setO2IsSet(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_partition_by_name_with_environment_context_result struct) throws org.apache.thrift.TException {
+ struct.validate();
+
+ oprot.writeStructBegin(STRUCT_DESC);
+ if (struct.isSetSuccess()) {
+ oprot.writeFieldBegin(SUCCESS_FIELD_DESC);
+ oprot.writeBool(struct.success);
+ oprot.writeFieldEnd();
+ }
+ if (struct.o1 != null) {
+ oprot.writeFieldBegin(O1_FIELD_DESC);
+ struct.o1.write(oprot);
+ oprot.writeFieldEnd();
+ }
+ if (struct.o2 != null) {
+ oprot.writeFieldBegin(O2_FIELD_DESC);
+ struct.o2.write(oprot);
+ oprot.writeFieldEnd();
+ }
+ oprot.writeFieldStop();
+ oprot.writeStructEnd();
+ }
+
+ }
+
+ private static class drop_partition_by_name_with_environment_context_resultTupleSchemeFactory implements SchemeFactory {
+ public drop_partition_by_name_with_environment_context_resultTupleScheme getScheme() {
+ return new drop_partition_by_name_with_environment_context_resultTupleScheme();
+ }
+ }
+
+ private static class drop_partition_by_name_with_environment_context_resultTupleScheme extends TupleScheme<drop_partition_by_name_with_environment_context_result> {
+
+ @Override
+ public void write(org.apache.thrift.protocol.TProtocol prot, drop_partition_by_name_with_environment_context_result struct) throws org.apache.thrift.TException {
+ TTupleProtocol oprot = (TTupleProtocol) prot;
+ BitSet optionals = new BitSet();
+ if (struct.isSetSuccess()) {
+ optionals.set(0);
+ }
+ if (struct.isSetO1()) {
+ optionals.set(1);
+ }
+ if (struct.isSetO2()) {
+ optionals.set(2);
+ }
+ oprot.writeBitSet(optionals, 3);
+ if (struct.isSetSuccess()) {
+ oprot.writeBool(struct.success);
+ }
+ if (struct.isSetO1()) {
+ struct.o1.write(oprot);
+ }
+ if (struct.isSetO2()) {
+ struct.o2.write(oprot);
+ }
+ }
+
+ @Override
+ public void read(org.apache.thrift.protocol.TProtocol prot, drop_partition_by_name_with_environment_context_result struct) throws org.apache.thrift.TException {
+ TTupleProtocol iprot = (TTupleProtocol) prot;
+ BitSet incoming = iprot.readBitSet(3);
+ if (incoming.get(0)) {
+ struct.success = iprot.readBool();
+ struct.setSuccessIsSet(true);
+ }
+ if (incoming.get(1)) {
+ struct.o1 = new NoSuchObjectException();
+ struct.o1.read(iprot);
+ struct.setO1IsSet(true);
+ }
+ if (incoming.get(2)) {
+ struct.o2 = new MetaException();
+ struct.o2.read(iprot);
+ struct.setO2IsSet(true);
+ }
+ }
+ }
+
+ }
+
+ public static class drop_partitions_req_args implements org.apache.thrift.TBase<drop_partitions_req_args, drop_partitions_req_args._Fields>, java.io.Serializable, Cloneable {
+ private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("drop_partitions_req_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_partitions_req_argsStandardSchemeFactory());
+ schemes.put(TupleScheme.class, new drop_partitions_req_argsTupleSchemeFactory());
+ }
+
+ private DropPartitionsRequest 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, DropPartitionsRequest.class)));
+ metaDataMap = Collections.unmodifiableMap(tmpMap);
+ org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(drop_partitions_req_args.class, metaDataMap);
+ }
+
+ public drop_partitions_req_args() {
+ }
+
+ public drop_partitions_req_args(
+ DropPartitionsRequest req)
+ {
+ this();
+ this.req = req;
+ }
+
+ /**
+ * Performs a deep copy on <i>other</i>.
+ */
+ public drop_partitions_req_args(drop_partitions_req_args other) {
+ if (other.isSetReq()) {
+ this.req = new DropPartitionsRequest(other.req);
+ }
+ }
+
+ public drop_partitions_req_args deepCopy() {
+ return new drop_partitions_req_args(this);
+ }
+
+ @Override
+ public void clear() {
+ this.req = null;
+ }
+
+ public DropPartitionsRequest getReq() {
+ return this.req;
+ }
+
+ public void setReq(DropPartitionsRequest 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((DropPartitionsRequest)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_partitions_req_args)
+ return this.equals((drop_partitions_req_args)that);
+ return false;
+ }
+
+ public boolean equals(drop_partitions_req_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() {
+ HashCodeBuilder builder = new HashCodeBuilder();
+
+ boolean present_req = true && (isSetReq());
+ builder.append(present_req);
+ if (present_req)
+ builder.append(req);
+
+ return builder.toHashCode();
+ }
+
+ public int compareTo(drop_partitions_req_args other) {
+ if (!getClass().equals(other.getClass())) {
+ return getClass().getName().compareTo(other.getClass().getName());
+ }
+
+ int lastComparison = 0;
+ drop_partitions_req_args typedOther = (drop_partitions_req_args)other;
+
+ lastComparison = Boolean.valueOf(isSetReq()).compareTo(typedOther.isSetReq());
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ if (isSetReq()) {
+ lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.req, typedOther.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_partitions_req_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_partitions_req_argsStandardSchemeFactory implements SchemeFactory {
+ public drop_partitions_req_argsStandardScheme getScheme() {
+ return new drop_partitions_req_argsStandardScheme();
+ }
+ }
+
+ private static class drop_partitions_req_argsStandardScheme extends StandardScheme<drop_partitions_req_args> {
+
+ public void read(org.apache.thrift.protocol.TProtocol iprot, drop_partitions_req_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 DropPartitionsRequest();
+ 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_partitions_req_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();
+ }
+
+ }
+
[... 2613 lines stripped ...]