You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hive.apache.org by da...@apache.org on 2015/09/22 07:04:03 UTC
[32/50] [abbrv] hive git commit: HIVE-11552 : implement basic methods
for getting/putting file metadata (Sergey Shelukhin, reviewed by Alan Gates)
http://git-wip-us.apache.org/repos/asf/hive/blob/129bed52/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 72b2cc3..9d72cd0 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
@@ -34,7 +34,7 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"})
-@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-8-14")
+@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-8-17")
public class ThriftHiveMetastore {
/**
@@ -292,6 +292,14 @@ public class ThriftHiveMetastore {
public void flushCache() throws org.apache.thrift.TException;
+ public GetFileMetadataByExprResult get_file_metadata_by_expr(GetFileMetadataByExprRequest req) throws org.apache.thrift.TException;
+
+ public GetFileMetadataResult get_file_metadata(GetFileMetadataRequest req) throws org.apache.thrift.TException;
+
+ public PutFileMetadataResult put_file_metadata(PutFileMetadataRequest req) throws org.apache.thrift.TException;
+
+ public ClearFileMetadataResult clear_file_metadata(ClearFileMetadataRequest req) throws org.apache.thrift.TException;
+
}
public interface AsyncIface extends com.facebook.fb303.FacebookService .AsyncIface {
@@ -546,6 +554,14 @@ public class ThriftHiveMetastore {
public void flushCache(org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
+ public void get_file_metadata_by_expr(GetFileMetadataByExprRequest req, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
+
+ public void get_file_metadata(GetFileMetadataRequest req, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
+
+ public void put_file_metadata(PutFileMetadataRequest req, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
+
+ public void clear_file_metadata(ClearFileMetadataRequest req, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
+
}
public static class Client extends com.facebook.fb303.FacebookService.Client implements Iface {
@@ -4242,6 +4258,98 @@ public class ThriftHiveMetastore {
return;
}
+ public GetFileMetadataByExprResult get_file_metadata_by_expr(GetFileMetadataByExprRequest req) throws org.apache.thrift.TException
+ {
+ send_get_file_metadata_by_expr(req);
+ return recv_get_file_metadata_by_expr();
+ }
+
+ public void send_get_file_metadata_by_expr(GetFileMetadataByExprRequest req) throws org.apache.thrift.TException
+ {
+ get_file_metadata_by_expr_args args = new get_file_metadata_by_expr_args();
+ args.setReq(req);
+ sendBase("get_file_metadata_by_expr", args);
+ }
+
+ public GetFileMetadataByExprResult recv_get_file_metadata_by_expr() throws org.apache.thrift.TException
+ {
+ get_file_metadata_by_expr_result result = new get_file_metadata_by_expr_result();
+ receiveBase(result, "get_file_metadata_by_expr");
+ if (result.isSetSuccess()) {
+ return result.success;
+ }
+ throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "get_file_metadata_by_expr failed: unknown result");
+ }
+
+ public GetFileMetadataResult get_file_metadata(GetFileMetadataRequest req) throws org.apache.thrift.TException
+ {
+ send_get_file_metadata(req);
+ return recv_get_file_metadata();
+ }
+
+ public void send_get_file_metadata(GetFileMetadataRequest req) throws org.apache.thrift.TException
+ {
+ get_file_metadata_args args = new get_file_metadata_args();
+ args.setReq(req);
+ sendBase("get_file_metadata", args);
+ }
+
+ public GetFileMetadataResult recv_get_file_metadata() throws org.apache.thrift.TException
+ {
+ get_file_metadata_result result = new get_file_metadata_result();
+ receiveBase(result, "get_file_metadata");
+ if (result.isSetSuccess()) {
+ return result.success;
+ }
+ throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "get_file_metadata failed: unknown result");
+ }
+
+ public PutFileMetadataResult put_file_metadata(PutFileMetadataRequest req) throws org.apache.thrift.TException
+ {
+ send_put_file_metadata(req);
+ return recv_put_file_metadata();
+ }
+
+ public void send_put_file_metadata(PutFileMetadataRequest req) throws org.apache.thrift.TException
+ {
+ put_file_metadata_args args = new put_file_metadata_args();
+ args.setReq(req);
+ sendBase("put_file_metadata", args);
+ }
+
+ public PutFileMetadataResult recv_put_file_metadata() throws org.apache.thrift.TException
+ {
+ put_file_metadata_result result = new put_file_metadata_result();
+ receiveBase(result, "put_file_metadata");
+ if (result.isSetSuccess()) {
+ return result.success;
+ }
+ throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "put_file_metadata failed: unknown result");
+ }
+
+ public ClearFileMetadataResult clear_file_metadata(ClearFileMetadataRequest req) throws org.apache.thrift.TException
+ {
+ send_clear_file_metadata(req);
+ return recv_clear_file_metadata();
+ }
+
+ public void send_clear_file_metadata(ClearFileMetadataRequest req) throws org.apache.thrift.TException
+ {
+ clear_file_metadata_args args = new clear_file_metadata_args();
+ args.setReq(req);
+ sendBase("clear_file_metadata", args);
+ }
+
+ public ClearFileMetadataResult recv_clear_file_metadata() throws org.apache.thrift.TException
+ {
+ clear_file_metadata_result result = new clear_file_metadata_result();
+ receiveBase(result, "clear_file_metadata");
+ if (result.isSetSuccess()) {
+ return result.success;
+ }
+ throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "clear_file_metadata failed: unknown result");
+ }
+
}
public static class AsyncClient extends com.facebook.fb303.FacebookService.AsyncClient implements AsyncIface {
public static class Factory implements org.apache.thrift.async.TAsyncClientFactory<AsyncClient> {
@@ -8704,6 +8812,134 @@ public class ThriftHiveMetastore {
}
}
+ public void get_file_metadata_by_expr(GetFileMetadataByExprRequest req, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException {
+ checkReady();
+ get_file_metadata_by_expr_call method_call = new get_file_metadata_by_expr_call(req, resultHandler, this, ___protocolFactory, ___transport);
+ this.___currentMethod = method_call;
+ ___manager.call(method_call);
+ }
+
+ public static class get_file_metadata_by_expr_call extends org.apache.thrift.async.TAsyncMethodCall {
+ private GetFileMetadataByExprRequest req;
+ public get_file_metadata_by_expr_call(GetFileMetadataByExprRequest 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("get_file_metadata_by_expr", org.apache.thrift.protocol.TMessageType.CALL, 0));
+ get_file_metadata_by_expr_args args = new get_file_metadata_by_expr_args();
+ args.setReq(req);
+ args.write(prot);
+ prot.writeMessageEnd();
+ }
+
+ public GetFileMetadataByExprResult getResult() throws org.apache.thrift.TException {
+ if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) {
+ throw new IllegalStateException("Method call not finished!");
+ }
+ org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array());
+ org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport);
+ return (new Client(prot)).recv_get_file_metadata_by_expr();
+ }
+ }
+
+ public void get_file_metadata(GetFileMetadataRequest req, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException {
+ checkReady();
+ get_file_metadata_call method_call = new get_file_metadata_call(req, resultHandler, this, ___protocolFactory, ___transport);
+ this.___currentMethod = method_call;
+ ___manager.call(method_call);
+ }
+
+ public static class get_file_metadata_call extends org.apache.thrift.async.TAsyncMethodCall {
+ private GetFileMetadataRequest req;
+ public get_file_metadata_call(GetFileMetadataRequest 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("get_file_metadata", org.apache.thrift.protocol.TMessageType.CALL, 0));
+ get_file_metadata_args args = new get_file_metadata_args();
+ args.setReq(req);
+ args.write(prot);
+ prot.writeMessageEnd();
+ }
+
+ public GetFileMetadataResult getResult() throws org.apache.thrift.TException {
+ if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) {
+ throw new IllegalStateException("Method call not finished!");
+ }
+ org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array());
+ org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport);
+ return (new Client(prot)).recv_get_file_metadata();
+ }
+ }
+
+ public void put_file_metadata(PutFileMetadataRequest req, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException {
+ checkReady();
+ put_file_metadata_call method_call = new put_file_metadata_call(req, resultHandler, this, ___protocolFactory, ___transport);
+ this.___currentMethod = method_call;
+ ___manager.call(method_call);
+ }
+
+ public static class put_file_metadata_call extends org.apache.thrift.async.TAsyncMethodCall {
+ private PutFileMetadataRequest req;
+ public put_file_metadata_call(PutFileMetadataRequest 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("put_file_metadata", org.apache.thrift.protocol.TMessageType.CALL, 0));
+ put_file_metadata_args args = new put_file_metadata_args();
+ args.setReq(req);
+ args.write(prot);
+ prot.writeMessageEnd();
+ }
+
+ public PutFileMetadataResult getResult() throws 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_put_file_metadata();
+ }
+ }
+
+ public void clear_file_metadata(ClearFileMetadataRequest req, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException {
+ checkReady();
+ clear_file_metadata_call method_call = new clear_file_metadata_call(req, resultHandler, this, ___protocolFactory, ___transport);
+ this.___currentMethod = method_call;
+ ___manager.call(method_call);
+ }
+
+ public static class clear_file_metadata_call extends org.apache.thrift.async.TAsyncMethodCall {
+ private ClearFileMetadataRequest req;
+ public clear_file_metadata_call(ClearFileMetadataRequest 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("clear_file_metadata", org.apache.thrift.protocol.TMessageType.CALL, 0));
+ clear_file_metadata_args args = new clear_file_metadata_args();
+ args.setReq(req);
+ args.write(prot);
+ prot.writeMessageEnd();
+ }
+
+ public ClearFileMetadataResult getResult() throws 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_clear_file_metadata();
+ }
+ }
+
}
public static class Processor<I extends Iface> extends com.facebook.fb303.FacebookService.Processor<I> implements org.apache.thrift.TProcessor {
@@ -8842,6 +9078,10 @@ public class ThriftHiveMetastore {
processMap.put("get_current_notificationEventId", new get_current_notificationEventId());
processMap.put("fire_listener_event", new fire_listener_event());
processMap.put("flushCache", new flushCache());
+ processMap.put("get_file_metadata_by_expr", new get_file_metadata_by_expr());
+ processMap.put("get_file_metadata", new get_file_metadata());
+ processMap.put("put_file_metadata", new put_file_metadata());
+ processMap.put("clear_file_metadata", new clear_file_metadata());
return processMap;
}
@@ -12086,6 +12326,86 @@ public class ThriftHiveMetastore {
}
}
+ public static class get_file_metadata_by_expr<I extends Iface> extends org.apache.thrift.ProcessFunction<I, get_file_metadata_by_expr_args> {
+ public get_file_metadata_by_expr() {
+ super("get_file_metadata_by_expr");
+ }
+
+ public get_file_metadata_by_expr_args getEmptyArgsInstance() {
+ return new get_file_metadata_by_expr_args();
+ }
+
+ protected boolean isOneway() {
+ return false;
+ }
+
+ public get_file_metadata_by_expr_result getResult(I iface, get_file_metadata_by_expr_args args) throws org.apache.thrift.TException {
+ get_file_metadata_by_expr_result result = new get_file_metadata_by_expr_result();
+ result.success = iface.get_file_metadata_by_expr(args.req);
+ return result;
+ }
+ }
+
+ public static class get_file_metadata<I extends Iface> extends org.apache.thrift.ProcessFunction<I, get_file_metadata_args> {
+ public get_file_metadata() {
+ super("get_file_metadata");
+ }
+
+ public get_file_metadata_args getEmptyArgsInstance() {
+ return new get_file_metadata_args();
+ }
+
+ protected boolean isOneway() {
+ return false;
+ }
+
+ public get_file_metadata_result getResult(I iface, get_file_metadata_args args) throws org.apache.thrift.TException {
+ get_file_metadata_result result = new get_file_metadata_result();
+ result.success = iface.get_file_metadata(args.req);
+ return result;
+ }
+ }
+
+ public static class put_file_metadata<I extends Iface> extends org.apache.thrift.ProcessFunction<I, put_file_metadata_args> {
+ public put_file_metadata() {
+ super("put_file_metadata");
+ }
+
+ public put_file_metadata_args getEmptyArgsInstance() {
+ return new put_file_metadata_args();
+ }
+
+ protected boolean isOneway() {
+ return false;
+ }
+
+ public put_file_metadata_result getResult(I iface, put_file_metadata_args args) throws org.apache.thrift.TException {
+ put_file_metadata_result result = new put_file_metadata_result();
+ result.success = iface.put_file_metadata(args.req);
+ return result;
+ }
+ }
+
+ public static class clear_file_metadata<I extends Iface> extends org.apache.thrift.ProcessFunction<I, clear_file_metadata_args> {
+ public clear_file_metadata() {
+ super("clear_file_metadata");
+ }
+
+ public clear_file_metadata_args getEmptyArgsInstance() {
+ return new clear_file_metadata_args();
+ }
+
+ protected boolean isOneway() {
+ return false;
+ }
+
+ public clear_file_metadata_result getResult(I iface, clear_file_metadata_args args) throws org.apache.thrift.TException {
+ clear_file_metadata_result result = new clear_file_metadata_result();
+ result.success = iface.clear_file_metadata(args.req);
+ return result;
+ }
+ }
+
}
public static class AsyncProcessor<I extends AsyncIface> extends com.facebook.fb303.FacebookService.AsyncProcessor<I> {
@@ -12224,6 +12544,10 @@ public class ThriftHiveMetastore {
processMap.put("get_current_notificationEventId", new get_current_notificationEventId());
processMap.put("fire_listener_event", new fire_listener_event());
processMap.put("flushCache", new flushCache());
+ processMap.put("get_file_metadata_by_expr", new get_file_metadata_by_expr());
+ processMap.put("get_file_metadata", new get_file_metadata());
+ processMap.put("put_file_metadata", new put_file_metadata());
+ processMap.put("clear_file_metadata", new clear_file_metadata());
return processMap;
}
@@ -19936,385 +20260,228 @@ public class ThriftHiveMetastore {
}
}
- }
-
- public static class getMetaConf_args implements org.apache.thrift.TBase<getMetaConf_args, getMetaConf_args._Fields>, java.io.Serializable, Cloneable, Comparable<getMetaConf_args> {
- private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("getMetaConf_args");
-
- private static final org.apache.thrift.protocol.TField KEY_FIELD_DESC = new org.apache.thrift.protocol.TField("key", org.apache.thrift.protocol.TType.STRING, (short)1);
-
- private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>();
- static {
- schemes.put(StandardScheme.class, new getMetaConf_argsStandardSchemeFactory());
- schemes.put(TupleScheme.class, new getMetaConf_argsTupleSchemeFactory());
- }
-
- private String key; // 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 {
- KEY((short)1, "key");
-
- private static final Map<String, _Fields> byName = new HashMap<String, _Fields>();
-
- static {
- for (_Fields field : EnumSet.allOf(_Fields.class)) {
- byName.put(field.getFieldName(), field);
- }
+ public static class get_file_metadata_by_expr<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, get_file_metadata_by_expr_args, GetFileMetadataByExprResult> {
+ public get_file_metadata_by_expr() {
+ super("get_file_metadata_by_expr");
}
- /**
- * Find the _Fields constant that matches fieldId, or null if its not found.
- */
- public static _Fields findByThriftId(int fieldId) {
- switch(fieldId) {
- case 1: // KEY
- return KEY;
- default:
- return null;
- }
+ public get_file_metadata_by_expr_args getEmptyArgsInstance() {
+ return new get_file_metadata_by_expr_args();
}
- /**
- * 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 AsyncMethodCallback<GetFileMetadataByExprResult> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
+ final org.apache.thrift.AsyncProcessFunction fcall = this;
+ return new AsyncMethodCallback<GetFileMetadataByExprResult>() {
+ public void onComplete(GetFileMetadataByExprResult o) {
+ get_file_metadata_by_expr_result result = new get_file_metadata_by_expr_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_file_metadata_by_expr_result result = new get_file_metadata_by_expr_result();
+ {
+ 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();
+ }
+ };
}
- public short getThriftFieldId() {
- return _thriftId;
+ protected boolean isOneway() {
+ return false;
}
- public String getFieldName() {
- return _fieldName;
+ public void start(I iface, get_file_metadata_by_expr_args args, org.apache.thrift.async.AsyncMethodCallback<GetFileMetadataByExprResult> resultHandler) throws TException {
+ iface.get_file_metadata_by_expr(args.req,resultHandler);
}
}
- // 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.KEY, new org.apache.thrift.meta_data.FieldMetaData("key", org.apache.thrift.TFieldRequirementType.DEFAULT,
- new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING)));
- metaDataMap = Collections.unmodifiableMap(tmpMap);
- org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(getMetaConf_args.class, metaDataMap);
- }
-
- public getMetaConf_args() {
- }
-
- public getMetaConf_args(
- String key)
- {
- this();
- this.key = key;
- }
-
- /**
- * Performs a deep copy on <i>other</i>.
- */
- public getMetaConf_args(getMetaConf_args other) {
- if (other.isSetKey()) {
- this.key = other.key;
+ public static class get_file_metadata<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, get_file_metadata_args, GetFileMetadataResult> {
+ public get_file_metadata() {
+ super("get_file_metadata");
}
- }
-
- public getMetaConf_args deepCopy() {
- return new getMetaConf_args(this);
- }
-
- @Override
- public void clear() {
- this.key = null;
- }
-
- public String getKey() {
- return this.key;
- }
-
- public void setKey(String key) {
- this.key = key;
- }
-
- public void unsetKey() {
- this.key = null;
- }
-
- /** Returns true if field key is set (has been assigned a value) and false otherwise */
- public boolean isSetKey() {
- return this.key != null;
- }
-
- public void setKeyIsSet(boolean value) {
- if (!value) {
- this.key = null;
- }
- }
-
- public void setFieldValue(_Fields field, Object value) {
- switch (field) {
- case KEY:
- if (value == null) {
- unsetKey();
- } else {
- setKey((String)value);
- }
- break;
+ public get_file_metadata_args getEmptyArgsInstance() {
+ return new get_file_metadata_args();
}
- }
-
- public Object getFieldValue(_Fields field) {
- switch (field) {
- case KEY:
- return getKey();
+ public AsyncMethodCallback<GetFileMetadataResult> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
+ final org.apache.thrift.AsyncProcessFunction fcall = this;
+ return new AsyncMethodCallback<GetFileMetadataResult>() {
+ public void onComplete(GetFileMetadataResult o) {
+ get_file_metadata_result result = new get_file_metadata_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_file_metadata_result result = new get_file_metadata_result();
+ {
+ 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();
+ }
+ };
}
- 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();
+ protected boolean isOneway() {
+ return false;
}
- switch (field) {
- case KEY:
- return isSetKey();
+ public void start(I iface, get_file_metadata_args args, org.apache.thrift.async.AsyncMethodCallback<GetFileMetadataResult> resultHandler) throws TException {
+ iface.get_file_metadata(args.req,resultHandler);
}
- throw new IllegalStateException();
}
- @Override
- public boolean equals(Object that) {
- if (that == null)
- return false;
- if (that instanceof getMetaConf_args)
- return this.equals((getMetaConf_args)that);
- return false;
- }
-
- public boolean equals(getMetaConf_args that) {
- if (that == null)
- return false;
-
- boolean this_present_key = true && this.isSetKey();
- boolean that_present_key = true && that.isSetKey();
- if (this_present_key || that_present_key) {
- if (!(this_present_key && that_present_key))
- return false;
- if (!this.key.equals(that.key))
- return false;
+ public static class put_file_metadata<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, put_file_metadata_args, PutFileMetadataResult> {
+ public put_file_metadata() {
+ super("put_file_metadata");
}
- return true;
- }
-
- @Override
- public int hashCode() {
- List<Object> list = new ArrayList<Object>();
-
- boolean present_key = true && (isSetKey());
- list.add(present_key);
- if (present_key)
- list.add(key);
-
- return list.hashCode();
- }
-
- @Override
- public int compareTo(getMetaConf_args other) {
- if (!getClass().equals(other.getClass())) {
- return getClass().getName().compareTo(other.getClass().getName());
+ public put_file_metadata_args getEmptyArgsInstance() {
+ return new put_file_metadata_args();
}
- int lastComparison = 0;
-
- lastComparison = Boolean.valueOf(isSetKey()).compareTo(other.isSetKey());
- if (lastComparison != 0) {
- return lastComparison;
- }
- if (isSetKey()) {
- lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.key, other.key);
- if (lastComparison != 0) {
- return lastComparison;
- }
+ public AsyncMethodCallback<PutFileMetadataResult> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
+ final org.apache.thrift.AsyncProcessFunction fcall = this;
+ return new AsyncMethodCallback<PutFileMetadataResult>() {
+ public void onComplete(PutFileMetadataResult o) {
+ put_file_metadata_result result = new put_file_metadata_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;
+ put_file_metadata_result result = new put_file_metadata_result();
+ {
+ 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();
+ }
+ };
}
- 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("getMetaConf_args(");
- boolean first = true;
-
- sb.append("key:");
- if (this.key == null) {
- sb.append("null");
- } else {
- sb.append(this.key);
+ protected boolean isOneway() {
+ return false;
}
- 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);
+ public void start(I iface, put_file_metadata_args args, org.apache.thrift.async.AsyncMethodCallback<PutFileMetadataResult> resultHandler) throws TException {
+ iface.put_file_metadata(args.req,resultHandler);
}
}
- 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);
+ public static class clear_file_metadata<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, clear_file_metadata_args, ClearFileMetadataResult> {
+ public clear_file_metadata() {
+ super("clear_file_metadata");
}
- }
- private static class getMetaConf_argsStandardSchemeFactory implements SchemeFactory {
- public getMetaConf_argsStandardScheme getScheme() {
- return new getMetaConf_argsStandardScheme();
+ public clear_file_metadata_args getEmptyArgsInstance() {
+ return new clear_file_metadata_args();
}
- }
-
- private static class getMetaConf_argsStandardScheme extends StandardScheme<getMetaConf_args> {
- public void read(org.apache.thrift.protocol.TProtocol iprot, getMetaConf_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;
+ public AsyncMethodCallback<ClearFileMetadataResult> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
+ final org.apache.thrift.AsyncProcessFunction fcall = this;
+ return new AsyncMethodCallback<ClearFileMetadataResult>() {
+ public void onComplete(ClearFileMetadataResult o) {
+ clear_file_metadata_result result = new clear_file_metadata_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();
}
- switch (schemeField.id) {
- case 1: // KEY
- if (schemeField.type == org.apache.thrift.protocol.TType.STRING) {
- struct.key = iprot.readString();
- struct.setKeyIsSet(true);
- } else {
- org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
- }
- break;
- default:
- org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+ public void onError(Exception e) {
+ byte msgType = org.apache.thrift.protocol.TMessageType.REPLY;
+ org.apache.thrift.TBase msg;
+ clear_file_metadata_result result = new clear_file_metadata_result();
+ {
+ 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();
}
- iprot.readFieldEnd();
- }
- iprot.readStructEnd();
- struct.validate();
- }
-
- public void write(org.apache.thrift.protocol.TProtocol oprot, getMetaConf_args struct) throws org.apache.thrift.TException {
- struct.validate();
-
- oprot.writeStructBegin(STRUCT_DESC);
- if (struct.key != null) {
- oprot.writeFieldBegin(KEY_FIELD_DESC);
- oprot.writeString(struct.key);
- oprot.writeFieldEnd();
- }
- oprot.writeFieldStop();
- oprot.writeStructEnd();
- }
-
- }
-
- private static class getMetaConf_argsTupleSchemeFactory implements SchemeFactory {
- public getMetaConf_argsTupleScheme getScheme() {
- return new getMetaConf_argsTupleScheme();
+ };
}
- }
-
- private static class getMetaConf_argsTupleScheme extends TupleScheme<getMetaConf_args> {
- @Override
- public void write(org.apache.thrift.protocol.TProtocol prot, getMetaConf_args struct) throws org.apache.thrift.TException {
- TTupleProtocol oprot = (TTupleProtocol) prot;
- BitSet optionals = new BitSet();
- if (struct.isSetKey()) {
- optionals.set(0);
- }
- oprot.writeBitSet(optionals, 1);
- if (struct.isSetKey()) {
- oprot.writeString(struct.key);
- }
+ protected boolean isOneway() {
+ return false;
}
- @Override
- public void read(org.apache.thrift.protocol.TProtocol prot, getMetaConf_args struct) throws org.apache.thrift.TException {
- TTupleProtocol iprot = (TTupleProtocol) prot;
- BitSet incoming = iprot.readBitSet(1);
- if (incoming.get(0)) {
- struct.key = iprot.readString();
- struct.setKeyIsSet(true);
- }
+ public void start(I iface, clear_file_metadata_args args, org.apache.thrift.async.AsyncMethodCallback<ClearFileMetadataResult> resultHandler) throws TException {
+ iface.clear_file_metadata(args.req,resultHandler);
}
}
}
- public static class getMetaConf_result implements org.apache.thrift.TBase<getMetaConf_result, getMetaConf_result._Fields>, java.io.Serializable, Cloneable, Comparable<getMetaConf_result> {
- private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("getMetaConf_result");
+ public static class getMetaConf_args implements org.apache.thrift.TBase<getMetaConf_args, getMetaConf_args._Fields>, java.io.Serializable, Cloneable, Comparable<getMetaConf_args> {
+ private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("getMetaConf_args");
- private static final org.apache.thrift.protocol.TField SUCCESS_FIELD_DESC = new org.apache.thrift.protocol.TField("success", org.apache.thrift.protocol.TType.STRING, (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 KEY_FIELD_DESC = new org.apache.thrift.protocol.TField("key", org.apache.thrift.protocol.TType.STRING, (short)1);
private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>();
static {
- schemes.put(StandardScheme.class, new getMetaConf_resultStandardSchemeFactory());
- schemes.put(TupleScheme.class, new getMetaConf_resultTupleSchemeFactory());
+ schemes.put(StandardScheme.class, new getMetaConf_argsStandardSchemeFactory());
+ schemes.put(TupleScheme.class, new getMetaConf_argsTupleSchemeFactory());
}
- private String success; // required
- private MetaException o1; // required
+ private String key; // 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");
+ KEY((short)1, "key");
private static final Map<String, _Fields> byName = new HashMap<String, _Fields>();
@@ -20329,10 +20496,371 @@ public class ThriftHiveMetastore {
*/
public static _Fields findByThriftId(int fieldId) {
switch(fieldId) {
- case 0: // SUCCESS
- return SUCCESS;
- case 1: // O1
- return O1;
+ case 1: // KEY
+ return KEY;
+ 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.KEY, new org.apache.thrift.meta_data.FieldMetaData("key", org.apache.thrift.TFieldRequirementType.DEFAULT,
+ new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING)));
+ metaDataMap = Collections.unmodifiableMap(tmpMap);
+ org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(getMetaConf_args.class, metaDataMap);
+ }
+
+ public getMetaConf_args() {
+ }
+
+ public getMetaConf_args(
+ String key)
+ {
+ this();
+ this.key = key;
+ }
+
+ /**
+ * Performs a deep copy on <i>other</i>.
+ */
+ public getMetaConf_args(getMetaConf_args other) {
+ if (other.isSetKey()) {
+ this.key = other.key;
+ }
+ }
+
+ public getMetaConf_args deepCopy() {
+ return new getMetaConf_args(this);
+ }
+
+ @Override
+ public void clear() {
+ this.key = null;
+ }
+
+ public String getKey() {
+ return this.key;
+ }
+
+ public void setKey(String key) {
+ this.key = key;
+ }
+
+ public void unsetKey() {
+ this.key = null;
+ }
+
+ /** Returns true if field key is set (has been assigned a value) and false otherwise */
+ public boolean isSetKey() {
+ return this.key != null;
+ }
+
+ public void setKeyIsSet(boolean value) {
+ if (!value) {
+ this.key = null;
+ }
+ }
+
+ public void setFieldValue(_Fields field, Object value) {
+ switch (field) {
+ case KEY:
+ if (value == null) {
+ unsetKey();
+ } else {
+ setKey((String)value);
+ }
+ break;
+
+ }
+ }
+
+ public Object getFieldValue(_Fields field) {
+ switch (field) {
+ case KEY:
+ return getKey();
+
+ }
+ 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 KEY:
+ return isSetKey();
+ }
+ throw new IllegalStateException();
+ }
+
+ @Override
+ public boolean equals(Object that) {
+ if (that == null)
+ return false;
+ if (that instanceof getMetaConf_args)
+ return this.equals((getMetaConf_args)that);
+ return false;
+ }
+
+ public boolean equals(getMetaConf_args that) {
+ if (that == null)
+ return false;
+
+ boolean this_present_key = true && this.isSetKey();
+ boolean that_present_key = true && that.isSetKey();
+ if (this_present_key || that_present_key) {
+ if (!(this_present_key && that_present_key))
+ return false;
+ if (!this.key.equals(that.key))
+ return false;
+ }
+
+ return true;
+ }
+
+ @Override
+ public int hashCode() {
+ List<Object> list = new ArrayList<Object>();
+
+ boolean present_key = true && (isSetKey());
+ list.add(present_key);
+ if (present_key)
+ list.add(key);
+
+ return list.hashCode();
+ }
+
+ @Override
+ public int compareTo(getMetaConf_args other) {
+ if (!getClass().equals(other.getClass())) {
+ return getClass().getName().compareTo(other.getClass().getName());
+ }
+
+ int lastComparison = 0;
+
+ lastComparison = Boolean.valueOf(isSetKey()).compareTo(other.isSetKey());
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ if (isSetKey()) {
+ lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.key, other.key);
+ 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("getMetaConf_args(");
+ boolean first = true;
+
+ sb.append("key:");
+ if (this.key == null) {
+ sb.append("null");
+ } else {
+ sb.append(this.key);
+ }
+ first = false;
+ sb.append(")");
+ return sb.toString();
+ }
+
+ public void validate() throws org.apache.thrift.TException {
+ // check for required fields
+ // check for sub-struct validity
+ }
+
+ private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException {
+ try {
+ write(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(out)));
+ } catch (org.apache.thrift.TException te) {
+ throw new java.io.IOException(te);
+ }
+ }
+
+ private void readObject(java.io.ObjectInputStream in) throws java.io.IOException, ClassNotFoundException {
+ try {
+ read(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(in)));
+ } catch (org.apache.thrift.TException te) {
+ throw new java.io.IOException(te);
+ }
+ }
+
+ private static class getMetaConf_argsStandardSchemeFactory implements SchemeFactory {
+ public getMetaConf_argsStandardScheme getScheme() {
+ return new getMetaConf_argsStandardScheme();
+ }
+ }
+
+ private static class getMetaConf_argsStandardScheme extends StandardScheme<getMetaConf_args> {
+
+ public void read(org.apache.thrift.protocol.TProtocol iprot, getMetaConf_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: // KEY
+ if (schemeField.type == org.apache.thrift.protocol.TType.STRING) {
+ struct.key = iprot.readString();
+ struct.setKeyIsSet(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, getMetaConf_args struct) throws org.apache.thrift.TException {
+ struct.validate();
+
+ oprot.writeStructBegin(STRUCT_DESC);
+ if (struct.key != null) {
+ oprot.writeFieldBegin(KEY_FIELD_DESC);
+ oprot.writeString(struct.key);
+ oprot.writeFieldEnd();
+ }
+ oprot.writeFieldStop();
+ oprot.writeStructEnd();
+ }
+
+ }
+
+ private static class getMetaConf_argsTupleSchemeFactory implements SchemeFactory {
+ public getMetaConf_argsTupleScheme getScheme() {
+ return new getMetaConf_argsTupleScheme();
+ }
+ }
+
+ private static class getMetaConf_argsTupleScheme extends TupleScheme<getMetaConf_args> {
+
+ @Override
+ public void write(org.apache.thrift.protocol.TProtocol prot, getMetaConf_args struct) throws org.apache.thrift.TException {
+ TTupleProtocol oprot = (TTupleProtocol) prot;
+ BitSet optionals = new BitSet();
+ if (struct.isSetKey()) {
+ optionals.set(0);
+ }
+ oprot.writeBitSet(optionals, 1);
+ if (struct.isSetKey()) {
+ oprot.writeString(struct.key);
+ }
+ }
+
+ @Override
+ public void read(org.apache.thrift.protocol.TProtocol prot, getMetaConf_args struct) throws org.apache.thrift.TException {
+ TTupleProtocol iprot = (TTupleProtocol) prot;
+ BitSet incoming = iprot.readBitSet(1);
+ if (incoming.get(0)) {
+ struct.key = iprot.readString();
+ struct.setKeyIsSet(true);
+ }
+ }
+ }
+
+ }
+
+ public static class getMetaConf_result implements org.apache.thrift.TBase<getMetaConf_result, getMetaConf_result._Fields>, java.io.Serializable, Cloneable, Comparable<getMetaConf_result> {
+ private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("getMetaConf_result");
+
+ private static final org.apache.thrift.protocol.TField SUCCESS_FIELD_DESC = new org.apache.thrift.protocol.TField("success", org.apache.thrift.protocol.TType.STRING, (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 Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>();
+ static {
+ schemes.put(StandardScheme.class, new getMetaConf_resultStandardSchemeFactory());
+ schemes.put(TupleScheme.class, new getMetaConf_resultTupleSchemeFactory());
+ }
+
+ private String success; // required
+ private MetaException o1; // 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");
+
+ 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;
default:
return null;
}
@@ -25331,13 +25859,13 @@ public class ThriftHiveMetastore {
case 0: // SUCCESS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list532 = iprot.readListBegin();
- struct.success = new ArrayList<String>(_list532.size);
- String _elem533;
- for (int _i534 = 0; _i534 < _list532.size; ++_i534)
+ org.apache.thrift.protocol.TList _list600 = iprot.readListBegin();
+ struct.success = new ArrayList<String>(_list600.size);
+ String _elem601;
+ for (int _i602 = 0; _i602 < _list600.size; ++_i602)
{
- _elem533 = iprot.readString();
- struct.success.add(_elem533);
+ _elem601 = iprot.readString();
+ struct.success.add(_elem601);
}
iprot.readListEnd();
}
@@ -25372,9 +25900,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 _iter535 : struct.success)
+ for (String _iter603 : struct.success)
{
- oprot.writeString(_iter535);
+ oprot.writeString(_iter603);
}
oprot.writeListEnd();
}
@@ -25413,9 +25941,9 @@ public class ThriftHiveMetastore {
if (struct.isSetSuccess()) {
{
oprot.writeI32(struct.success.size());
- for (String _iter536 : struct.success)
+ for (String _iter604 : struct.success)
{
- oprot.writeString(_iter536);
+ oprot.writeString(_iter604);
}
}
}
@@ -25430,13 +25958,13 @@ public class ThriftHiveMetastore {
BitSet incoming = iprot.readBitSet(2);
if (incoming.get(0)) {
{
- org.apache.thrift.protocol.TList _list537 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
- struct.success = new ArrayList<String>(_list537.size);
- String _elem538;
- for (int _i539 = 0; _i539 < _list537.size; ++_i539)
+ org.apache.thrift.protocol.TList _list605 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+ struct.success = new ArrayList<String>(_list605.size);
+ String _elem606;
+ for (int _i607 = 0; _i607 < _list605.size; ++_i607)
{
- _elem538 = iprot.readString();
- struct.success.add(_elem538);
+ _elem606 = iprot.readString();
+ struct.success.add(_elem606);
}
}
struct.setSuccessIsSet(true);
@@ -26090,13 +26618,13 @@ public class ThriftHiveMetastore {
case 0: // SUCCESS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list540 = iprot.readListBegin();
- struct.success = new ArrayList<String>(_list540.size);
- String _elem541;
- for (int _i542 = 0; _i542 < _list540.size; ++_i542)
+ org.apache.thrift.protocol.TList _list608 = iprot.readListBegin();
+ struct.success = new ArrayList<String>(_list608.size);
+ String _elem609;
+ for (int _i610 = 0; _i610 < _list608.size; ++_i610)
{
- _elem541 = iprot.readString();
- struct.success.add(_elem541);
+ _elem609 = iprot.readString();
+ struct.success.add(_elem609);
}
iprot.readListEnd();
}
@@ -26131,9 +26659,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 _iter543 : struct.success)
+ for (String _iter611 : struct.success)
{
- oprot.writeString(_iter543);
+ oprot.writeString(_iter611);
}
oprot.writeListEnd();
}
@@ -26172,9 +26700,9 @@ public class ThriftHiveMetastore {
if (struct.isSetSuccess()) {
{
oprot.writeI32(struct.success.size());
- for (String _iter544 : struct.success)
+ for (String _iter612 : struct.success)
{
- oprot.writeString(_iter544);
+ oprot.writeString(_iter612);
}
}
}
@@ -26189,13 +26717,13 @@ public class ThriftHiveMetastore {
BitSet incoming = iprot.readBitSet(2);
if (incoming.get(0)) {
{
- org.apache.thrift.protocol.TList _list545 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
- struct.success = new ArrayList<String>(_list545.size);
- String _elem546;
- for (int _i547 = 0; _i547 < _list545.size; ++_i547)
+ org.apache.thrift.protocol.TList _list613 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+ struct.success = new ArrayList<String>(_list613.size);
+ String _elem614;
+ for (int _i615 = 0; _i615 < _list613.size; ++_i615)
{
- _elem546 = iprot.readString();
- struct.success.add(_elem546);
+ _elem614 = iprot.readString();
+ struct.success.add(_elem614);
}
}
struct.setSuccessIsSet(true);
@@ -30802,16 +31330,16 @@ public class ThriftHiveMetastore {
case 0: // SUCCESS
if (schemeField.type == org.apache.thrift.protocol.TType.MAP) {
{
- org.apache.thrift.protocol.TMap _map548 = iprot.readMapBegin();
- struct.success = new HashMap<String,Type>(2*_map548.size);
- String _key549;
- Type _val550;
- for (int _i551 = 0; _i551 < _map548.size; ++_i551)
+ org.apache.thrift.protocol.TMap _map616 = iprot.readMapBegin();
+ struct.success = new HashMap<String,Type>(2*_map616.size);
+ String _key617;
+ Type _val618;
+ for (int _i619 = 0; _i619 < _map616.size; ++_i619)
{
- _key549 = iprot.readString();
- _val550 = new Type();
- _val550.read(iprot);
- struct.success.put(_key549, _val550);
+ _key617 = iprot.readString();
+ _val618 = new Type();
+ _val618.read(iprot);
+ struct.success.put(_key617, _val618);
}
iprot.readMapEnd();
}
@@ -30846,10 +31374,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> _iter552 : struct.success.entrySet())
+ for (Map.Entry<String, Type> _iter620 : struct.success.entrySet())
{
- oprot.writeString(_iter552.getKey());
- _iter552.getValue().write(oprot);
+ oprot.writeString(_iter620.getKey());
+ _iter620.getValue().write(oprot);
}
oprot.writeMapEnd();
}
@@ -30888,10 +31416,10 @@ public class ThriftHiveMetastore {
if (struct.isSetSuccess()) {
{
oprot.writeI32(struct.success.size());
- for (Map.Entry<String, Type> _iter553 : struct.success.entrySet())
+ for (Map.Entry<String, Type> _iter621 : struct.success.entrySet())
{
- oprot.writeString(_iter553.getKey());
- _iter553.getValue().write(oprot);
+ oprot.writeString(_iter621.getKey());
+ _iter621.getValue().write(oprot);
}
}
}
@@ -30906,16 +31434,16 @@ public class ThriftHiveMetastore {
BitSet incoming = iprot.readBitSet(2);
if (incoming.get(0)) {
{
- org.apache.thrift.protocol.TMap _map554 = 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*_map554.size);
- String _key555;
- Type _val556;
- for (int _i557 = 0; _i557 < _map554.size; ++_i557)
+ org.apache.thrift.protocol.TMap _map622 = 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*_map622.size);
+ String _key623;
+ Type _val624;
+ for (int _i625 = 0; _i625 < _map622.size; ++_i625)
{
- _key555 = iprot.readString();
- _val556 = new Type();
- _val556.read(iprot);
- struct.success.put(_key555, _val556);
+ _key623 = iprot.readString();
+ _val624 = new Type();
+ _val624.read(iprot);
+ struct.success.put(_key623, _val624);
}
}
struct.setSuccessIsSet(true);
@@ -31950,14 +32478,14 @@ public class ThriftHiveMetastore {
case 0: // SUCCESS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list558 = iprot.readListBegin();
- struct.success = new ArrayList<FieldSchema>(_list558.size);
- FieldSchema _elem559;
- for (int _i560 = 0; _i560 < _list558.size; ++_i560)
+ org.apache.thrift.protocol.TList _list626 = iprot.readListBegin();
+ struct.success = new ArrayList<FieldSchema>(_list626.size);
+ FieldSchema _elem627;
+ for (int _i628 = 0; _i628 < _list626.size; ++_i628)
{
- _elem559 = new FieldSchema();
- _elem559.read(iprot);
- struct.success.add(_elem559);
+ _elem627 = new FieldSchema();
+ _elem627.read(iprot);
+ struct.success.add(_elem627);
}
iprot.readListEnd();
}
@@ -32010,9 +32538,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 _iter561 : struct.success)
+ for (FieldSchema _iter629 : struct.success)
{
- _iter561.write(oprot);
+ _iter629.write(oprot);
}
oprot.writeListEnd();
}
@@ -32067,9 +32595,9 @@ public class ThriftHiveMetastore {
if (struct.isSetSuccess()) {
{
oprot.writeI32(struct.success.size());
- for (FieldSchema _iter562 : struct.success)
+ for (FieldSchema _iter630 : struct.success)
{
- _iter562.write(oprot);
+ _iter630.write(oprot);
}
}
}
@@ -32090,14 +32618,14 @@ public class ThriftHiveMetastore {
BitSet incoming = iprot.readBitSet(4);
if (incoming.get(0)) {
{
- org.apache.thrift.protocol.TList _list563 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.success = new ArrayList<FieldSchema>(_list563.size);
- FieldSchema _elem564;
- for (int _i565 = 0; _i565 < _list563.size; ++_i565)
+ org.apache.thrift.protocol.TList _list631 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.success = new ArrayList<FieldSchema>(_list631.size);
+ FieldSchema _elem632;
+ for (int _i633 = 0; _i633 < _list631.size; ++_i633)
{
- _elem564 = new FieldSchema();
- _elem564.read(iprot);
- struct.success.add(_elem564);
+ _elem632 = new FieldSchema();
+ _elem632.read(iprot);
+ struct.success.add(_elem632);
}
}
struct.setSuccessIsSet(true);
@@ -33251,14 +33779,14 @@ public class ThriftHiveMetastore {
case 0: // SUCCESS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list566 = iprot.readListBegin();
- struct.success = new ArrayList<FieldSchema>(_list566.size);
- FieldSchema _elem567;
- for (int _i568 = 0; _i568 < _list566.size; ++_i568)
+ org.apache.thrift.protocol.TList _list634 = iprot.readListBegin();
+ struct.success = new ArrayList<FieldSchema>(_list634.size);
+ FieldSchema _elem635;
+ for (int _i636 = 0; _i636 < _list634.size; ++_i636)
{
- _elem567 = new FieldSchema();
- _elem567.read(iprot);
- struct.success.add(_elem567);
+ _elem635 = new FieldSchema();
+ _elem635.read(iprot);
+ struct.success.add(_elem635);
}
iprot.readListEnd();
}
@@ -33311,9 +33839,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 _iter569 : struct.success)
+ for (FieldSchema _iter637 : struct.success)
{
- _iter569.write(oprot);
+ _iter637.write(oprot);
}
oprot.writeListEnd();
}
@@ -33368,9 +33896,9 @@ public class ThriftHiveMetastore {
if (struct.isSetSuccess()) {
{
oprot.writeI32(struct.success.size());
- for (FieldSchema _iter570 : struct.success)
+ for (FieldSchema _iter638 : struct.success)
{
- _iter570.write(oprot);
+ _iter638.write(oprot);
}
}
}
@@ -33391,14 +33919,14 @@ public class ThriftHiveMetastore {
BitSet incoming = iprot.readBitSet(4);
if (incoming.get(0)) {
{
- org.apache.thrift.protocol.TList _list571 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.success = new ArrayList<FieldSchema>(_list571.size);
- FieldSchema _elem572;
- for (int _i573 = 0; _i573 < _list571.size; ++_i573)
+ org.apache.thrift.protocol.TList _list639 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.success = new ArrayList<FieldSchema>(_list639.size);
+ FieldSchema _elem640;
+ for (int _i641 = 0; _i641 < _list639.size; ++_i641)
{
- _elem572 = new FieldSchema();
- _elem572.read(iprot);
- struct.success.add(_elem572);
+ _elem640 = new FieldSchema();
+ _elem640.read(iprot);
+ struct.success.add(_elem640);
}
}
struct.setSuccessIsSet(true);
@@ -34443,14 +34971,14 @@ public class ThriftHiveMetastore {
case 0: // SUCCESS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list574 = iprot.readListBegin();
- struct.success = new ArrayList<FieldSchema>(_list574.size);
- FieldSchema _elem575;
- for (int _i576 = 0; _i576 < _list574.size; ++_i576)
+ org.apache.thrift.protocol.TList _list642 = iprot.readListBegin();
+ struct.success = new ArrayList<FieldSchema>(_list642.size);
+ FieldSchema _elem643;
+ for (int _i644 = 0; _i644 < _list642.size; ++_i644)
{
- _elem575 = new FieldSchema();
- _elem575.read(iprot);
- struct.success.add(_elem575);
+ _elem643 = new FieldSchema();
+ _elem643.read(iprot);
+ struct.success.add(_elem643);
}
iprot.readListEnd();
}
@@ -34503,9 +35031,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 _iter577 : struct.success)
+ for (FieldSchema _iter645 : struct.success)
{
- _iter577.write(oprot);
+ _iter645.write(oprot);
}
oprot.writeListEnd();
}
@@ -34560,9 +35088,9 @@ public class ThriftHiveMetastore {
if (struct.isSetSuccess()) {
{
oprot.writeI32(struct.success.size());
- for (FieldSchema _iter578 : struct.success)
+ for (FieldSchema _iter646 : struct.success)
{
- _iter578.write(oprot);
+ _iter646.write(oprot);
}
}
}
@@ -34583,14 +35111,14 @@ public class ThriftHiveMetastore {
BitSet incoming = iprot.readBitSet(4);
if (incoming.get(0)) {
{
- org.apache.thrift.protocol.TList _list579 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.success = new ArrayList<FieldSchema>(_list579.size);
- FieldSchema _elem580;
- for (int _i581 = 0; _i581 < _list579.size; ++_i581)
+ org.apache.thrift.protocol.TList _list647 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.success = new ArrayList<FieldSchema>(_list647.size);
+ FieldSchema _elem648;
+ for (int _i649 = 0; _i649 < _list647.size; ++_i649)
{
- _elem580 = new FieldSchema();
- _elem580.read(iprot);
- struct.success.add(_elem580);
+ _elem648 = new FieldSchema();
+ _elem648.read(iprot);
+ struct.success.add(_elem648);
}
}
struct.setSuccessIsSet(true);
@@ -35744,14 +36272,14 @@ public class ThriftHiveMetastore {
case 0: // SUCCESS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list582 = iprot.readListBegin();
- struct.success = new ArrayList<FieldSchema>(_list582.size);
- FieldSchema _elem583;
- for (int _i584 = 0; _i584 < _list582.size; ++_i584)
+ org.apache.thrift.protocol.TList _list650 = iprot.readListBegin();
+ struct.success = new ArrayList<FieldSchema>(_list650.size);
+ FieldSchema _elem651;
+ for (int _i652 = 0; _i652 < _list650.size; ++_i652)
{
- _elem583 = new FieldSchema();
- _elem583.read(iprot);
- struct.success.add(_elem583);
+ _elem651 = new FieldSchema();
+ _elem651.read(iprot);
+ struct.success.add(_elem651);
}
iprot.readListEnd();
}
@@ -35804,9 +36332,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 _iter585 : struct.success)
+ for (FieldSchema _iter653 : struct.success)
{
- _iter585.write(oprot);
+ _iter653.write(oprot);
}
oprot.writeListEnd();
}
@@ -35861,9 +36389,9 @@ public class ThriftHiveMetastore {
if (struct.isSetSuccess()) {
{
oprot.writeI32(struct.success.size());
- for (FieldSchema _iter586 : struct.success)
+ for (FieldSchema _iter654 : struct.success)
{
- _iter586.write(oprot);
+ _iter654.write(oprot);
}
}
}
@@ -35884,14 +36412,14 @@ public class ThriftHiveMetastore {
BitSet incoming = iprot.readBitSet(4);
if (incoming.get(0)) {
{
- org.apache.thrift.protocol.TList _list587 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.success = new ArrayList<FieldSchema>(_list587.size);
- FieldSchema _elem588;
- for (int _i589 = 0; _i589 < _list587.size; ++_i589)
+ org.apache.thrift.protocol.TList _list655 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.success = new ArrayList<FieldSchema>(_list655.size);
+ FieldSchema _elem656;
+ for (int _i657 = 0; _i657 < _list655.size; ++_i657)
{
- _elem588 = new FieldSchema();
- _elem588.read(iprot);
- struct.success.add(_elem588);
+ _elem656 = new FieldSchema();
+ _elem656.read(iprot);
+ struct.success.add(_elem656);
}
}
struct.setSuccessIsSet(true);
@@ -41131,13 +41659,13 @@ public class ThriftHiveMetastore {
case 0: // SUCCESS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list590 = iprot.readListBegin();
- struct.success = new ArrayList<String>(_list590.size);
- String _elem591;
- for (int _i592 = 0; _i592 < _list590.size; ++_i592)
+ org.apache.thrift.protocol.TList _list658 = iprot.readListBegin();
+ struct.success = new ArrayList<String>(_list658.size);
+ String _elem659;
+ for (int _i660 = 0; _i660 < _list658.size; ++_i660)
{
- _elem591 = iprot.readString();
- struct.success.add(_elem591);
+ _elem659 = iprot.readString();
+ struct.success.add(_elem659);
}
iprot.readListEnd();
}
@@ -41172,9 +41700,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 _iter593 : struct.success)
+ for (String _iter661 : struct.success)
{
- oprot.writeString(_iter593);
+ oprot.writeString(_iter661);
}
oprot.writeListEnd();
}
@@ -41213,9 +41741,9 @@ public class ThriftHiveMetastore {
if (struct.isSetSuccess()) {
{
oprot.writeI32(struct.success.size());
- for (String _iter594 : struct.success)
+ for (String _iter662 : struct.success)
{
- oprot.writeString(_iter594);
+ oprot.writeString(_iter662);
}
}
}
@@ -41230,13 +41758,13 @@ public class ThriftHiveMetastore {
BitSet incoming = iprot.readBitSet(2);
if (incoming.get(0)) {
{
- org.apache.thrift.protocol.TList _list595 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
- struct.success = new ArrayList<String>(_list595.size);
- String _elem596;
- for (int _i597 = 0; _i597 < _list595.size; ++_i597)
+ org.apache.thrift.protocol.TList _list663 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+ struct.success = new ArrayList<String>(_list663.size);
+ String _elem664;
+ for (int _i665 = 0; _i665 < _list663.size; ++_i665)
{
- _elem596 = iprot.readString();
- struct.success.add(_elem596);
+ _elem664 = iprot.readString();
+ struct.success.add(_elem664);
}
}
struct.setSuccessIsSet(true);
@@ -42002,13 +42530,13 @@ public class ThriftHiveMetastore {
case 0: // SUCCESS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list598 = iprot.readListBegin();
- struct.success = new ArrayList<String>(_list598.size);
- String _elem599;
- for (int _i600 = 0; _i600 < _list598.size; ++_i600)
+ org.apache.thrift.protocol.TList _list666 = iprot.readListBegin();
+ struct.success = new ArrayList<String>(_list666.size);
+ String _elem667;
+ for (int _i668 = 0; _i668 < _list666.size; ++_i668)
{
- _elem599 = iprot.readString();
- struct.success.add(_elem599);
+ _elem667 = iprot.readString();
+ struct.success.add(_elem667);
}
iprot.readListEnd();
}
@@ -42043,9 +42571,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 _iter601 : struct.success)
+ for (String _iter669 : struct.success)
{
- oprot.writeString(_iter601);
+ oprot.writeString(_iter669);
}
oprot.writeListEnd();
}
@@ -42084,9 +42612,9 @@ public class ThriftHiveMetastore {
if (struct.isSetSuccess()) {
{
oprot.writeI32(struct.success.size());
- for (String _iter602 : struct.success)
+ for (String _iter670 : struct.success)
{
- oprot.writeString(_iter602);
+ oprot.writeString(_iter670);
}
}
}
@@ -42101,13 +42629,13 @@ public class ThriftHiveMetastore {
BitSet incoming = iprot.readBitSet(2);
if (incoming.get(0)) {
{
- org.apache.thrift.protocol.TList _list603 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
- struct.success = new ArrayList<String>(_list603.size);
- String _elem604;
- for (int _i605 = 0; _i605 < _list603.size; ++_i605)
+ org.apache.thrift.protocol.TList _list671 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+ struct.success = new ArrayList<String>(_list671.size);
+ String _elem672;
+ for (int _i673 = 0; _i673 < _list671.size; ++_i673)
{
- _elem604 = iprot.readString();
- struct.success.add(_elem604);
+ _elem672 = iprot.readString();
+ struct.success.add(_elem672);
}
}
struct.setSuccessIsSet(true);
@@ -43560,13 +44088,13 @@ public class ThriftHiveMetastore {
case 2: // TBL_NAMES
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list606 = iprot.readListBegin();
- struct.tbl_names = new ArrayList<String>(_list606.size);
- String _elem607;
- for (int _i608 = 0; _i608 < _list606.size; ++_i608)
+ org.apache.thrift.protocol.TList _list674 = iprot.readListBegin();
+ struct.tbl_names = new ArrayList<String>(_list674.size);
+ String _elem675;
+ for (int _i676 = 0; _i676 < _list674.size; ++_i676)
{
- _elem607 = iprot.readString();
- struct.tbl_names.add(_elem607);
+ _elem675 = iprot.readString();
+ struct.tbl_names.add(_elem675);
}
iprot.readListEnd();
}
@@ -43597,9 +44125,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 _iter609 : struct.tbl_names)
+ for (String _iter677 : struct.tbl_names)
{
- oprot.writeString(_iter609);
+ oprot.writeString(_iter677);
}
oprot.writeListEnd();
}
@@ -43636,9 +44164,9 @@ public class ThriftHiveMetastore {
if (struct.isSetTbl_names()) {
{
oprot.writeI32(struct.tbl_names.size());
- for (String _iter610 : struct.tbl_names)
+ for (String _iter678 : struct.tbl_names)
{
- oprot.writeString(_iter610);
+ oprot.writeString(_iter678);
}
}
}
@@ -43654,13 +44182,13 @@ public class ThriftHiveMetastore {
}
if (incoming.get(1)) {
{
- org.apache.thrift.protocol.TList _list611 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
- struct.tbl_names = new ArrayList<String>(_list611.size);
- String _elem612;
- for (int _i613 = 0; _i613 < _list611.size; ++_i613)
+ org.apache.thrift.protocol.TList _list679 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+ struct.tbl_names = new ArrayList<String>(_list679.size);
+ String _elem680;
+ for (int _i681 = 0; _i681 < _list679.size; ++_i681)
{
- _elem612 = iprot.readString();
- struct.tbl_names.add(_elem612);
+ _elem680 = iprot.readString();
+ struct.tbl_names.add(_elem680);
}
}
struct.setTbl_namesIsSet(true);
@@ -44228,14 +44756,14 @@ public class ThriftHiveMetastore {
case 0: // SUCCESS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list614 = iprot.readListBegin();
- struct.success = new ArrayList<Table>(_list614.size);
- Table _elem615;
- for (int _i616 = 0; _i616 < _list614.size; ++_i616)
+ org.apache.thrift.protocol.TList _list682 = iprot.readListBegin();
+ struct.success = new ArrayList<Table>(_list682.size);
+ Table _elem683;
+ for (int _i684 = 0; _i684 < _list682.size; ++_i684)
{
- _elem615 = new Table();
- _elem615.read(iprot);
- struct.success.add(_elem615);
+ _elem683 = new Table();
+ _elem683.read(iprot);
+ struct.success.add(_elem683);
}
iprot.readListEnd();
}
@@ -44288,9 +44816,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 _iter617 : struct.success)
+ for (Table _iter685 : struct.success)
{
- _iter617.write(oprot);
+ _iter685.write(oprot);
}
oprot.writeListEnd();
}
@@ -44345,9 +44873,9 @@ public class ThriftHiveMetastore {
if (struct.isSetSuccess()) {
{
oprot.writeI32(struct.success.size());
- for (Table _iter618 : struct.success)
+ for (Table _iter686 : struct.success)
{
- _iter618.write(oprot);
+ _iter686.write(oprot);
}
}
}
@@ -44368,14 +44896,14 @@ public class ThriftHiveMetastore {
BitSet incoming = iprot.readBitSet(4);
if (incoming.get(0)) {
{
- org.apache.thrift.protocol.TList _list619 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.success = new ArrayList<Table>(_list619.size);
- Table _elem620;
- for (int _i621 = 0; _i621 < _list619.size; ++_i621)
+ org.apache.thrift.protocol.TList _list687 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.success = new ArrayList<Table>(_list687.size);
+ Table _elem688;
+ for (int _i689 = 0; _i689 < _list687.size; ++_i689)
{
- _elem620 = new Table();
- _elem620.read(iprot);
- struct.success.add(_elem620);
+ _elem688 = new Table();
+ _elem688.read(iprot);
+ struct.success.add(_elem688);
}
}
struct.setSuccessIsSet(true);
@@ -45521,13 +46049,13 @@ public class ThriftHiveMetastore {
case 0: // SUCCESS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _li
<TRUNCATED>