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/03/05 01:20:57 UTC
svn commit: r1574266 [12/23] - in /hive/trunk:
common/src/java/org/apache/hadoop/hive/conf/
itests/hive-unit/src/test/java/org/apache/hadoop/hive/metastore/ metastore/
metastore/if/ metastore/scripts/upgrade/derby/
metastore/scripts/upgrade/mysql/ meta...
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=1574266&r1=1574265&r2=1574266&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 Mar 5 00:20:53 2014
@@ -222,6 +222,30 @@ public class ThriftHiveMetastore {
public void cancel_delegation_token(String token_str_form) throws MetaException, org.apache.thrift.TException;
+ public GetOpenTxnsResponse get_open_txns() throws org.apache.thrift.TException;
+
+ public GetOpenTxnsInfoResponse get_open_txns_info() throws org.apache.thrift.TException;
+
+ public OpenTxnsResponse open_txns(OpenTxnRequest rqst) throws org.apache.thrift.TException;
+
+ public void abort_txn(AbortTxnRequest rqst) throws NoSuchTxnException, org.apache.thrift.TException;
+
+ public void commit_txn(CommitTxnRequest rqst) throws NoSuchTxnException, TxnAbortedException, org.apache.thrift.TException;
+
+ public LockResponse lock(LockRequest rqst) throws NoSuchTxnException, TxnAbortedException, org.apache.thrift.TException;
+
+ public LockResponse check_lock(CheckLockRequest rqst) throws NoSuchTxnException, TxnAbortedException, NoSuchLockException, org.apache.thrift.TException;
+
+ public void unlock(UnlockRequest rqst) throws NoSuchLockException, TxnOpenException, org.apache.thrift.TException;
+
+ public ShowLocksResponse show_locks(ShowLocksRequest rqst) throws org.apache.thrift.TException;
+
+ public void heartbeat(HeartbeatRequest ids) throws NoSuchLockException, NoSuchTxnException, TxnAbortedException, org.apache.thrift.TException;
+
+ public void compact(CompactionRequest rqst) throws org.apache.thrift.TException;
+
+ public ShowCompactResponse show_compact(ShowCompactRequest rqst) throws org.apache.thrift.TException;
+
}
public interface AsyncIface extends com.facebook.fb303.FacebookService .AsyncIface {
@@ -410,6 +434,30 @@ public class ThriftHiveMetastore {
public void cancel_delegation_token(String token_str_form, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.cancel_delegation_token_call> resultHandler) throws org.apache.thrift.TException;
+ public void get_open_txns(org.apache.thrift.async.AsyncMethodCallback<AsyncClient.get_open_txns_call> resultHandler) throws org.apache.thrift.TException;
+
+ public void get_open_txns_info(org.apache.thrift.async.AsyncMethodCallback<AsyncClient.get_open_txns_info_call> resultHandler) throws org.apache.thrift.TException;
+
+ public void open_txns(OpenTxnRequest rqst, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.open_txns_call> resultHandler) throws org.apache.thrift.TException;
+
+ public void abort_txn(AbortTxnRequest rqst, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.abort_txn_call> resultHandler) throws org.apache.thrift.TException;
+
+ public void commit_txn(CommitTxnRequest rqst, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.commit_txn_call> resultHandler) throws org.apache.thrift.TException;
+
+ public void lock(LockRequest rqst, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.lock_call> resultHandler) throws org.apache.thrift.TException;
+
+ public void check_lock(CheckLockRequest rqst, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.check_lock_call> resultHandler) throws org.apache.thrift.TException;
+
+ public void unlock(UnlockRequest rqst, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.unlock_call> resultHandler) throws org.apache.thrift.TException;
+
+ public void show_locks(ShowLocksRequest rqst, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.show_locks_call> resultHandler) throws org.apache.thrift.TException;
+
+ public void heartbeat(HeartbeatRequest ids, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.heartbeat_call> resultHandler) throws org.apache.thrift.TException;
+
+ public void compact(CompactionRequest rqst, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.compact_call> resultHandler) throws org.apache.thrift.TException;
+
+ public void show_compact(ShowCompactRequest rqst, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.show_compact_call> resultHandler) throws org.apache.thrift.TException;
+
}
public static class Client extends com.facebook.fb303.FacebookService.Client implements Iface {
@@ -3237,6 +3285,304 @@ public class ThriftHiveMetastore {
return;
}
+ public GetOpenTxnsResponse get_open_txns() throws org.apache.thrift.TException
+ {
+ send_get_open_txns();
+ return recv_get_open_txns();
+ }
+
+ public void send_get_open_txns() throws org.apache.thrift.TException
+ {
+ get_open_txns_args args = new get_open_txns_args();
+ sendBase("get_open_txns", args);
+ }
+
+ public GetOpenTxnsResponse recv_get_open_txns() throws org.apache.thrift.TException
+ {
+ get_open_txns_result result = new get_open_txns_result();
+ receiveBase(result, "get_open_txns");
+ if (result.isSetSuccess()) {
+ return result.success;
+ }
+ throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "get_open_txns failed: unknown result");
+ }
+
+ public GetOpenTxnsInfoResponse get_open_txns_info() throws org.apache.thrift.TException
+ {
+ send_get_open_txns_info();
+ return recv_get_open_txns_info();
+ }
+
+ public void send_get_open_txns_info() throws org.apache.thrift.TException
+ {
+ get_open_txns_info_args args = new get_open_txns_info_args();
+ sendBase("get_open_txns_info", args);
+ }
+
+ public GetOpenTxnsInfoResponse recv_get_open_txns_info() throws org.apache.thrift.TException
+ {
+ get_open_txns_info_result result = new get_open_txns_info_result();
+ receiveBase(result, "get_open_txns_info");
+ if (result.isSetSuccess()) {
+ return result.success;
+ }
+ throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "get_open_txns_info failed: unknown result");
+ }
+
+ public OpenTxnsResponse open_txns(OpenTxnRequest rqst) throws org.apache.thrift.TException
+ {
+ send_open_txns(rqst);
+ return recv_open_txns();
+ }
+
+ public void send_open_txns(OpenTxnRequest rqst) throws org.apache.thrift.TException
+ {
+ open_txns_args args = new open_txns_args();
+ args.setRqst(rqst);
+ sendBase("open_txns", args);
+ }
+
+ public OpenTxnsResponse recv_open_txns() throws org.apache.thrift.TException
+ {
+ open_txns_result result = new open_txns_result();
+ receiveBase(result, "open_txns");
+ if (result.isSetSuccess()) {
+ return result.success;
+ }
+ throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "open_txns failed: unknown result");
+ }
+
+ public void abort_txn(AbortTxnRequest rqst) throws NoSuchTxnException, org.apache.thrift.TException
+ {
+ send_abort_txn(rqst);
+ recv_abort_txn();
+ }
+
+ public void send_abort_txn(AbortTxnRequest rqst) throws org.apache.thrift.TException
+ {
+ abort_txn_args args = new abort_txn_args();
+ args.setRqst(rqst);
+ sendBase("abort_txn", args);
+ }
+
+ public void recv_abort_txn() throws NoSuchTxnException, org.apache.thrift.TException
+ {
+ abort_txn_result result = new abort_txn_result();
+ receiveBase(result, "abort_txn");
+ if (result.o1 != null) {
+ throw result.o1;
+ }
+ return;
+ }
+
+ public void commit_txn(CommitTxnRequest rqst) throws NoSuchTxnException, TxnAbortedException, org.apache.thrift.TException
+ {
+ send_commit_txn(rqst);
+ recv_commit_txn();
+ }
+
+ public void send_commit_txn(CommitTxnRequest rqst) throws org.apache.thrift.TException
+ {
+ commit_txn_args args = new commit_txn_args();
+ args.setRqst(rqst);
+ sendBase("commit_txn", args);
+ }
+
+ public void recv_commit_txn() throws NoSuchTxnException, TxnAbortedException, org.apache.thrift.TException
+ {
+ commit_txn_result result = new commit_txn_result();
+ receiveBase(result, "commit_txn");
+ if (result.o1 != null) {
+ throw result.o1;
+ }
+ if (result.o2 != null) {
+ throw result.o2;
+ }
+ return;
+ }
+
+ public LockResponse lock(LockRequest rqst) throws NoSuchTxnException, TxnAbortedException, org.apache.thrift.TException
+ {
+ send_lock(rqst);
+ return recv_lock();
+ }
+
+ public void send_lock(LockRequest rqst) throws org.apache.thrift.TException
+ {
+ lock_args args = new lock_args();
+ args.setRqst(rqst);
+ sendBase("lock", args);
+ }
+
+ public LockResponse recv_lock() throws NoSuchTxnException, TxnAbortedException, org.apache.thrift.TException
+ {
+ lock_result result = new lock_result();
+ receiveBase(result, "lock");
+ 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, "lock failed: unknown result");
+ }
+
+ public LockResponse check_lock(CheckLockRequest rqst) throws NoSuchTxnException, TxnAbortedException, NoSuchLockException, org.apache.thrift.TException
+ {
+ send_check_lock(rqst);
+ return recv_check_lock();
+ }
+
+ public void send_check_lock(CheckLockRequest rqst) throws org.apache.thrift.TException
+ {
+ check_lock_args args = new check_lock_args();
+ args.setRqst(rqst);
+ sendBase("check_lock", args);
+ }
+
+ public LockResponse recv_check_lock() throws NoSuchTxnException, TxnAbortedException, NoSuchLockException, org.apache.thrift.TException
+ {
+ check_lock_result result = new check_lock_result();
+ receiveBase(result, "check_lock");
+ if (result.isSetSuccess()) {
+ return result.success;
+ }
+ if (result.o1 != null) {
+ throw result.o1;
+ }
+ if (result.o2 != null) {
+ throw result.o2;
+ }
+ if (result.o3 != null) {
+ throw result.o3;
+ }
+ throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "check_lock failed: unknown result");
+ }
+
+ public void unlock(UnlockRequest rqst) throws NoSuchLockException, TxnOpenException, org.apache.thrift.TException
+ {
+ send_unlock(rqst);
+ recv_unlock();
+ }
+
+ public void send_unlock(UnlockRequest rqst) throws org.apache.thrift.TException
+ {
+ unlock_args args = new unlock_args();
+ args.setRqst(rqst);
+ sendBase("unlock", args);
+ }
+
+ public void recv_unlock() throws NoSuchLockException, TxnOpenException, org.apache.thrift.TException
+ {
+ unlock_result result = new unlock_result();
+ receiveBase(result, "unlock");
+ if (result.o1 != null) {
+ throw result.o1;
+ }
+ if (result.o2 != null) {
+ throw result.o2;
+ }
+ return;
+ }
+
+ public ShowLocksResponse show_locks(ShowLocksRequest rqst) throws org.apache.thrift.TException
+ {
+ send_show_locks(rqst);
+ return recv_show_locks();
+ }
+
+ public void send_show_locks(ShowLocksRequest rqst) throws org.apache.thrift.TException
+ {
+ show_locks_args args = new show_locks_args();
+ args.setRqst(rqst);
+ sendBase("show_locks", args);
+ }
+
+ public ShowLocksResponse recv_show_locks() throws org.apache.thrift.TException
+ {
+ show_locks_result result = new show_locks_result();
+ receiveBase(result, "show_locks");
+ if (result.isSetSuccess()) {
+ return result.success;
+ }
+ throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "show_locks failed: unknown result");
+ }
+
+ public void heartbeat(HeartbeatRequest ids) throws NoSuchLockException, NoSuchTxnException, TxnAbortedException, org.apache.thrift.TException
+ {
+ send_heartbeat(ids);
+ recv_heartbeat();
+ }
+
+ public void send_heartbeat(HeartbeatRequest ids) throws org.apache.thrift.TException
+ {
+ heartbeat_args args = new heartbeat_args();
+ args.setIds(ids);
+ sendBase("heartbeat", args);
+ }
+
+ public void recv_heartbeat() throws NoSuchLockException, NoSuchTxnException, TxnAbortedException, org.apache.thrift.TException
+ {
+ heartbeat_result result = new heartbeat_result();
+ receiveBase(result, "heartbeat");
+ if (result.o1 != null) {
+ throw result.o1;
+ }
+ if (result.o2 != null) {
+ throw result.o2;
+ }
+ if (result.o3 != null) {
+ throw result.o3;
+ }
+ return;
+ }
+
+ public void compact(CompactionRequest rqst) throws org.apache.thrift.TException
+ {
+ send_compact(rqst);
+ recv_compact();
+ }
+
+ public void send_compact(CompactionRequest rqst) throws org.apache.thrift.TException
+ {
+ compact_args args = new compact_args();
+ args.setRqst(rqst);
+ sendBase("compact", args);
+ }
+
+ public void recv_compact() throws org.apache.thrift.TException
+ {
+ compact_result result = new compact_result();
+ receiveBase(result, "compact");
+ return;
+ }
+
+ public ShowCompactResponse show_compact(ShowCompactRequest rqst) throws org.apache.thrift.TException
+ {
+ send_show_compact(rqst);
+ return recv_show_compact();
+ }
+
+ public void send_show_compact(ShowCompactRequest rqst) throws org.apache.thrift.TException
+ {
+ show_compact_args args = new show_compact_args();
+ args.setRqst(rqst);
+ sendBase("show_compact", args);
+ }
+
+ public ShowCompactResponse recv_show_compact() throws org.apache.thrift.TException
+ {
+ show_compact_result result = new show_compact_result();
+ receiveBase(result, "show_compact");
+ if (result.isSetSuccess()) {
+ return result.success;
+ }
+ throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "show_compact 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> {
@@ -6619,6 +6965,384 @@ public class ThriftHiveMetastore {
}
}
+ public void get_open_txns(org.apache.thrift.async.AsyncMethodCallback<get_open_txns_call> resultHandler) throws org.apache.thrift.TException {
+ checkReady();
+ get_open_txns_call method_call = new get_open_txns_call(resultHandler, this, ___protocolFactory, ___transport);
+ this.___currentMethod = method_call;
+ ___manager.call(method_call);
+ }
+
+ public static class get_open_txns_call extends org.apache.thrift.async.TAsyncMethodCall {
+ public get_open_txns_call(org.apache.thrift.async.AsyncMethodCallback<get_open_txns_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);
+ }
+
+ public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
+ prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("get_open_txns", org.apache.thrift.protocol.TMessageType.CALL, 0));
+ get_open_txns_args args = new get_open_txns_args();
+ args.write(prot);
+ prot.writeMessageEnd();
+ }
+
+ public GetOpenTxnsResponse 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_open_txns();
+ }
+ }
+
+ public void get_open_txns_info(org.apache.thrift.async.AsyncMethodCallback<get_open_txns_info_call> resultHandler) throws org.apache.thrift.TException {
+ checkReady();
+ get_open_txns_info_call method_call = new get_open_txns_info_call(resultHandler, this, ___protocolFactory, ___transport);
+ this.___currentMethod = method_call;
+ ___manager.call(method_call);
+ }
+
+ public static class get_open_txns_info_call extends org.apache.thrift.async.TAsyncMethodCall {
+ public get_open_txns_info_call(org.apache.thrift.async.AsyncMethodCallback<get_open_txns_info_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);
+ }
+
+ public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
+ prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("get_open_txns_info", org.apache.thrift.protocol.TMessageType.CALL, 0));
+ get_open_txns_info_args args = new get_open_txns_info_args();
+ args.write(prot);
+ prot.writeMessageEnd();
+ }
+
+ public GetOpenTxnsInfoResponse 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_open_txns_info();
+ }
+ }
+
+ public void open_txns(OpenTxnRequest rqst, org.apache.thrift.async.AsyncMethodCallback<open_txns_call> resultHandler) throws org.apache.thrift.TException {
+ checkReady();
+ open_txns_call method_call = new open_txns_call(rqst, resultHandler, this, ___protocolFactory, ___transport);
+ this.___currentMethod = method_call;
+ ___manager.call(method_call);
+ }
+
+ public static class open_txns_call extends org.apache.thrift.async.TAsyncMethodCall {
+ private OpenTxnRequest rqst;
+ public open_txns_call(OpenTxnRequest rqst, org.apache.thrift.async.AsyncMethodCallback<open_txns_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.rqst = rqst;
+ }
+
+ public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
+ prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("open_txns", org.apache.thrift.protocol.TMessageType.CALL, 0));
+ open_txns_args args = new open_txns_args();
+ args.setRqst(rqst);
+ args.write(prot);
+ prot.writeMessageEnd();
+ }
+
+ public OpenTxnsResponse 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_open_txns();
+ }
+ }
+
+ public void abort_txn(AbortTxnRequest rqst, org.apache.thrift.async.AsyncMethodCallback<abort_txn_call> resultHandler) throws org.apache.thrift.TException {
+ checkReady();
+ abort_txn_call method_call = new abort_txn_call(rqst, resultHandler, this, ___protocolFactory, ___transport);
+ this.___currentMethod = method_call;
+ ___manager.call(method_call);
+ }
+
+ public static class abort_txn_call extends org.apache.thrift.async.TAsyncMethodCall {
+ private AbortTxnRequest rqst;
+ public abort_txn_call(AbortTxnRequest rqst, org.apache.thrift.async.AsyncMethodCallback<abort_txn_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.rqst = rqst;
+ }
+
+ public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
+ prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("abort_txn", org.apache.thrift.protocol.TMessageType.CALL, 0));
+ abort_txn_args args = new abort_txn_args();
+ args.setRqst(rqst);
+ args.write(prot);
+ prot.writeMessageEnd();
+ }
+
+ public void getResult() throws NoSuchTxnException, org.apache.thrift.TException {
+ if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) {
+ throw new IllegalStateException("Method call not finished!");
+ }
+ org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array());
+ org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport);
+ (new Client(prot)).recv_abort_txn();
+ }
+ }
+
+ public void commit_txn(CommitTxnRequest rqst, org.apache.thrift.async.AsyncMethodCallback<commit_txn_call> resultHandler) throws org.apache.thrift.TException {
+ checkReady();
+ commit_txn_call method_call = new commit_txn_call(rqst, resultHandler, this, ___protocolFactory, ___transport);
+ this.___currentMethod = method_call;
+ ___manager.call(method_call);
+ }
+
+ public static class commit_txn_call extends org.apache.thrift.async.TAsyncMethodCall {
+ private CommitTxnRequest rqst;
+ public commit_txn_call(CommitTxnRequest rqst, org.apache.thrift.async.AsyncMethodCallback<commit_txn_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.rqst = rqst;
+ }
+
+ public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
+ prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("commit_txn", org.apache.thrift.protocol.TMessageType.CALL, 0));
+ commit_txn_args args = new commit_txn_args();
+ args.setRqst(rqst);
+ args.write(prot);
+ prot.writeMessageEnd();
+ }
+
+ public void getResult() throws NoSuchTxnException, TxnAbortedException, org.apache.thrift.TException {
+ if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) {
+ throw new IllegalStateException("Method call not finished!");
+ }
+ org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array());
+ org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport);
+ (new Client(prot)).recv_commit_txn();
+ }
+ }
+
+ public void lock(LockRequest rqst, org.apache.thrift.async.AsyncMethodCallback<lock_call> resultHandler) throws org.apache.thrift.TException {
+ checkReady();
+ lock_call method_call = new lock_call(rqst, resultHandler, this, ___protocolFactory, ___transport);
+ this.___currentMethod = method_call;
+ ___manager.call(method_call);
+ }
+
+ public static class lock_call extends org.apache.thrift.async.TAsyncMethodCall {
+ private LockRequest rqst;
+ public lock_call(LockRequest rqst, org.apache.thrift.async.AsyncMethodCallback<lock_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.rqst = rqst;
+ }
+
+ public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
+ prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("lock", org.apache.thrift.protocol.TMessageType.CALL, 0));
+ lock_args args = new lock_args();
+ args.setRqst(rqst);
+ args.write(prot);
+ prot.writeMessageEnd();
+ }
+
+ public LockResponse getResult() throws NoSuchTxnException, TxnAbortedException, 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_lock();
+ }
+ }
+
+ public void check_lock(CheckLockRequest rqst, org.apache.thrift.async.AsyncMethodCallback<check_lock_call> resultHandler) throws org.apache.thrift.TException {
+ checkReady();
+ check_lock_call method_call = new check_lock_call(rqst, resultHandler, this, ___protocolFactory, ___transport);
+ this.___currentMethod = method_call;
+ ___manager.call(method_call);
+ }
+
+ public static class check_lock_call extends org.apache.thrift.async.TAsyncMethodCall {
+ private CheckLockRequest rqst;
+ public check_lock_call(CheckLockRequest rqst, org.apache.thrift.async.AsyncMethodCallback<check_lock_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.rqst = rqst;
+ }
+
+ public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
+ prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("check_lock", org.apache.thrift.protocol.TMessageType.CALL, 0));
+ check_lock_args args = new check_lock_args();
+ args.setRqst(rqst);
+ args.write(prot);
+ prot.writeMessageEnd();
+ }
+
+ public LockResponse getResult() throws NoSuchTxnException, TxnAbortedException, NoSuchLockException, 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_check_lock();
+ }
+ }
+
+ public void unlock(UnlockRequest rqst, org.apache.thrift.async.AsyncMethodCallback<unlock_call> resultHandler) throws org.apache.thrift.TException {
+ checkReady();
+ unlock_call method_call = new unlock_call(rqst, resultHandler, this, ___protocolFactory, ___transport);
+ this.___currentMethod = method_call;
+ ___manager.call(method_call);
+ }
+
+ public static class unlock_call extends org.apache.thrift.async.TAsyncMethodCall {
+ private UnlockRequest rqst;
+ public unlock_call(UnlockRequest rqst, org.apache.thrift.async.AsyncMethodCallback<unlock_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.rqst = rqst;
+ }
+
+ public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
+ prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("unlock", org.apache.thrift.protocol.TMessageType.CALL, 0));
+ unlock_args args = new unlock_args();
+ args.setRqst(rqst);
+ args.write(prot);
+ prot.writeMessageEnd();
+ }
+
+ public void getResult() throws NoSuchLockException, TxnOpenException, org.apache.thrift.TException {
+ if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) {
+ throw new IllegalStateException("Method call not finished!");
+ }
+ org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array());
+ org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport);
+ (new Client(prot)).recv_unlock();
+ }
+ }
+
+ public void show_locks(ShowLocksRequest rqst, org.apache.thrift.async.AsyncMethodCallback<show_locks_call> resultHandler) throws org.apache.thrift.TException {
+ checkReady();
+ show_locks_call method_call = new show_locks_call(rqst, resultHandler, this, ___protocolFactory, ___transport);
+ this.___currentMethod = method_call;
+ ___manager.call(method_call);
+ }
+
+ public static class show_locks_call extends org.apache.thrift.async.TAsyncMethodCall {
+ private ShowLocksRequest rqst;
+ public show_locks_call(ShowLocksRequest rqst, org.apache.thrift.async.AsyncMethodCallback<show_locks_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.rqst = rqst;
+ }
+
+ public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
+ prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("show_locks", org.apache.thrift.protocol.TMessageType.CALL, 0));
+ show_locks_args args = new show_locks_args();
+ args.setRqst(rqst);
+ args.write(prot);
+ prot.writeMessageEnd();
+ }
+
+ public ShowLocksResponse 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_show_locks();
+ }
+ }
+
+ public void heartbeat(HeartbeatRequest ids, org.apache.thrift.async.AsyncMethodCallback<heartbeat_call> resultHandler) throws org.apache.thrift.TException {
+ checkReady();
+ heartbeat_call method_call = new heartbeat_call(ids, resultHandler, this, ___protocolFactory, ___transport);
+ this.___currentMethod = method_call;
+ ___manager.call(method_call);
+ }
+
+ public static class heartbeat_call extends org.apache.thrift.async.TAsyncMethodCall {
+ private HeartbeatRequest ids;
+ public heartbeat_call(HeartbeatRequest ids, org.apache.thrift.async.AsyncMethodCallback<heartbeat_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.ids = ids;
+ }
+
+ public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
+ prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("heartbeat", org.apache.thrift.protocol.TMessageType.CALL, 0));
+ heartbeat_args args = new heartbeat_args();
+ args.setIds(ids);
+ args.write(prot);
+ prot.writeMessageEnd();
+ }
+
+ public void getResult() throws NoSuchLockException, NoSuchTxnException, TxnAbortedException, org.apache.thrift.TException {
+ if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) {
+ throw new IllegalStateException("Method call not finished!");
+ }
+ org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array());
+ org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport);
+ (new Client(prot)).recv_heartbeat();
+ }
+ }
+
+ public void compact(CompactionRequest rqst, org.apache.thrift.async.AsyncMethodCallback<compact_call> resultHandler) throws org.apache.thrift.TException {
+ checkReady();
+ compact_call method_call = new compact_call(rqst, resultHandler, this, ___protocolFactory, ___transport);
+ this.___currentMethod = method_call;
+ ___manager.call(method_call);
+ }
+
+ public static class compact_call extends org.apache.thrift.async.TAsyncMethodCall {
+ private CompactionRequest rqst;
+ public compact_call(CompactionRequest rqst, org.apache.thrift.async.AsyncMethodCallback<compact_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.rqst = rqst;
+ }
+
+ public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
+ prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("compact", org.apache.thrift.protocol.TMessageType.CALL, 0));
+ compact_args args = new compact_args();
+ args.setRqst(rqst);
+ args.write(prot);
+ prot.writeMessageEnd();
+ }
+
+ public void 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);
+ (new Client(prot)).recv_compact();
+ }
+ }
+
+ public void show_compact(ShowCompactRequest rqst, org.apache.thrift.async.AsyncMethodCallback<show_compact_call> resultHandler) throws org.apache.thrift.TException {
+ checkReady();
+ show_compact_call method_call = new show_compact_call(rqst, resultHandler, this, ___protocolFactory, ___transport);
+ this.___currentMethod = method_call;
+ ___manager.call(method_call);
+ }
+
+ public static class show_compact_call extends org.apache.thrift.async.TAsyncMethodCall {
+ private ShowCompactRequest rqst;
+ public show_compact_call(ShowCompactRequest rqst, org.apache.thrift.async.AsyncMethodCallback<show_compact_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.rqst = rqst;
+ }
+
+ public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
+ prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("show_compact", org.apache.thrift.protocol.TMessageType.CALL, 0));
+ show_compact_args args = new show_compact_args();
+ args.setRqst(rqst);
+ args.write(prot);
+ prot.writeMessageEnd();
+ }
+
+ public ShowCompactResponse 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_show_compact();
+ }
+ }
+
}
public static class Processor<I extends Iface> extends com.facebook.fb303.FacebookService.Processor<I> implements org.apache.thrift.TProcessor {
@@ -6724,6 +7448,18 @@ public class ThriftHiveMetastore {
processMap.put("get_delegation_token", new get_delegation_token());
processMap.put("renew_delegation_token", new renew_delegation_token());
processMap.put("cancel_delegation_token", new cancel_delegation_token());
+ processMap.put("get_open_txns", new get_open_txns());
+ processMap.put("get_open_txns_info", new get_open_txns_info());
+ processMap.put("open_txns", new open_txns());
+ processMap.put("abort_txn", new abort_txn());
+ processMap.put("commit_txn", new commit_txn());
+ processMap.put("lock", new lock());
+ processMap.put("check_lock", new check_lock());
+ processMap.put("unlock", new unlock());
+ processMap.put("show_locks", new show_locks());
+ processMap.put("heartbeat", new heartbeat());
+ processMap.put("compact", new compact());
+ processMap.put("show_compact", new show_compact());
return processMap;
}
@@ -9176,75 +9912,353 @@ public class ThriftHiveMetastore {
}
}
- }
+ public static class get_open_txns<I extends Iface> extends org.apache.thrift.ProcessFunction<I, get_open_txns_args> {
+ public get_open_txns() {
+ super("get_open_txns");
+ }
- public static class create_database_args implements org.apache.thrift.TBase<create_database_args, create_database_args._Fields>, java.io.Serializable, Cloneable {
- private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("create_database_args");
+ public get_open_txns_args getEmptyArgsInstance() {
+ return new get_open_txns_args();
+ }
- private static final org.apache.thrift.protocol.TField DATABASE_FIELD_DESC = new org.apache.thrift.protocol.TField("database", org.apache.thrift.protocol.TType.STRUCT, (short)1);
+ protected boolean isOneway() {
+ return false;
+ }
- private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>();
- static {
- schemes.put(StandardScheme.class, new create_database_argsStandardSchemeFactory());
- schemes.put(TupleScheme.class, new create_database_argsTupleSchemeFactory());
+ public get_open_txns_result getResult(I iface, get_open_txns_args args) throws org.apache.thrift.TException {
+ get_open_txns_result result = new get_open_txns_result();
+ result.success = iface.get_open_txns();
+ return result;
+ }
}
- private Database database; // 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 {
- DATABASE((short)1, "database");
-
- 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_open_txns_info<I extends Iface> extends org.apache.thrift.ProcessFunction<I, get_open_txns_info_args> {
+ public get_open_txns_info() {
+ super("get_open_txns_info");
}
- /**
- * Find the _Fields constant that matches fieldId, or null if its not found.
- */
- public static _Fields findByThriftId(int fieldId) {
- switch(fieldId) {
- case 1: // DATABASE
- return DATABASE;
- default:
- return null;
- }
+ public get_open_txns_info_args getEmptyArgsInstance() {
+ return new get_open_txns_info_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;
+ protected boolean isOneway() {
+ return false;
}
- /**
- * Find the _Fields constant that matches name, or null if its not found.
- */
- public static _Fields findByName(String name) {
- return byName.get(name);
+ public get_open_txns_info_result getResult(I iface, get_open_txns_info_args args) throws org.apache.thrift.TException {
+ get_open_txns_info_result result = new get_open_txns_info_result();
+ result.success = iface.get_open_txns_info();
+ return result;
}
+ }
- private final short _thriftId;
- private final String _fieldName;
-
- _Fields(short thriftId, String fieldName) {
- _thriftId = thriftId;
- _fieldName = fieldName;
+ public static class open_txns<I extends Iface> extends org.apache.thrift.ProcessFunction<I, open_txns_args> {
+ public open_txns() {
+ super("open_txns");
}
- public short getThriftFieldId() {
- return _thriftId;
+ public open_txns_args getEmptyArgsInstance() {
+ return new open_txns_args();
}
- public String getFieldName() {
+ protected boolean isOneway() {
+ return false;
+ }
+
+ public open_txns_result getResult(I iface, open_txns_args args) throws org.apache.thrift.TException {
+ open_txns_result result = new open_txns_result();
+ result.success = iface.open_txns(args.rqst);
+ return result;
+ }
+ }
+
+ public static class abort_txn<I extends Iface> extends org.apache.thrift.ProcessFunction<I, abort_txn_args> {
+ public abort_txn() {
+ super("abort_txn");
+ }
+
+ public abort_txn_args getEmptyArgsInstance() {
+ return new abort_txn_args();
+ }
+
+ protected boolean isOneway() {
+ return false;
+ }
+
+ public abort_txn_result getResult(I iface, abort_txn_args args) throws org.apache.thrift.TException {
+ abort_txn_result result = new abort_txn_result();
+ try {
+ iface.abort_txn(args.rqst);
+ } catch (NoSuchTxnException o1) {
+ result.o1 = o1;
+ }
+ return result;
+ }
+ }
+
+ public static class commit_txn<I extends Iface> extends org.apache.thrift.ProcessFunction<I, commit_txn_args> {
+ public commit_txn() {
+ super("commit_txn");
+ }
+
+ public commit_txn_args getEmptyArgsInstance() {
+ return new commit_txn_args();
+ }
+
+ protected boolean isOneway() {
+ return false;
+ }
+
+ public commit_txn_result getResult(I iface, commit_txn_args args) throws org.apache.thrift.TException {
+ commit_txn_result result = new commit_txn_result();
+ try {
+ iface.commit_txn(args.rqst);
+ } catch (NoSuchTxnException o1) {
+ result.o1 = o1;
+ } catch (TxnAbortedException o2) {
+ result.o2 = o2;
+ }
+ return result;
+ }
+ }
+
+ public static class lock<I extends Iface> extends org.apache.thrift.ProcessFunction<I, lock_args> {
+ public lock() {
+ super("lock");
+ }
+
+ public lock_args getEmptyArgsInstance() {
+ return new lock_args();
+ }
+
+ protected boolean isOneway() {
+ return false;
+ }
+
+ public lock_result getResult(I iface, lock_args args) throws org.apache.thrift.TException {
+ lock_result result = new lock_result();
+ try {
+ result.success = iface.lock(args.rqst);
+ } catch (NoSuchTxnException o1) {
+ result.o1 = o1;
+ } catch (TxnAbortedException o2) {
+ result.o2 = o2;
+ }
+ return result;
+ }
+ }
+
+ public static class check_lock<I extends Iface> extends org.apache.thrift.ProcessFunction<I, check_lock_args> {
+ public check_lock() {
+ super("check_lock");
+ }
+
+ public check_lock_args getEmptyArgsInstance() {
+ return new check_lock_args();
+ }
+
+ protected boolean isOneway() {
+ return false;
+ }
+
+ public check_lock_result getResult(I iface, check_lock_args args) throws org.apache.thrift.TException {
+ check_lock_result result = new check_lock_result();
+ try {
+ result.success = iface.check_lock(args.rqst);
+ } catch (NoSuchTxnException o1) {
+ result.o1 = o1;
+ } catch (TxnAbortedException o2) {
+ result.o2 = o2;
+ } catch (NoSuchLockException o3) {
+ result.o3 = o3;
+ }
+ return result;
+ }
+ }
+
+ public static class unlock<I extends Iface> extends org.apache.thrift.ProcessFunction<I, unlock_args> {
+ public unlock() {
+ super("unlock");
+ }
+
+ public unlock_args getEmptyArgsInstance() {
+ return new unlock_args();
+ }
+
+ protected boolean isOneway() {
+ return false;
+ }
+
+ public unlock_result getResult(I iface, unlock_args args) throws org.apache.thrift.TException {
+ unlock_result result = new unlock_result();
+ try {
+ iface.unlock(args.rqst);
+ } catch (NoSuchLockException o1) {
+ result.o1 = o1;
+ } catch (TxnOpenException o2) {
+ result.o2 = o2;
+ }
+ return result;
+ }
+ }
+
+ public static class show_locks<I extends Iface> extends org.apache.thrift.ProcessFunction<I, show_locks_args> {
+ public show_locks() {
+ super("show_locks");
+ }
+
+ public show_locks_args getEmptyArgsInstance() {
+ return new show_locks_args();
+ }
+
+ protected boolean isOneway() {
+ return false;
+ }
+
+ public show_locks_result getResult(I iface, show_locks_args args) throws org.apache.thrift.TException {
+ show_locks_result result = new show_locks_result();
+ result.success = iface.show_locks(args.rqst);
+ return result;
+ }
+ }
+
+ public static class heartbeat<I extends Iface> extends org.apache.thrift.ProcessFunction<I, heartbeat_args> {
+ public heartbeat() {
+ super("heartbeat");
+ }
+
+ public heartbeat_args getEmptyArgsInstance() {
+ return new heartbeat_args();
+ }
+
+ protected boolean isOneway() {
+ return false;
+ }
+
+ public heartbeat_result getResult(I iface, heartbeat_args args) throws org.apache.thrift.TException {
+ heartbeat_result result = new heartbeat_result();
+ try {
+ iface.heartbeat(args.ids);
+ } catch (NoSuchLockException o1) {
+ result.o1 = o1;
+ } catch (NoSuchTxnException o2) {
+ result.o2 = o2;
+ } catch (TxnAbortedException o3) {
+ result.o3 = o3;
+ }
+ return result;
+ }
+ }
+
+ public static class compact<I extends Iface> extends org.apache.thrift.ProcessFunction<I, compact_args> {
+ public compact() {
+ super("compact");
+ }
+
+ public compact_args getEmptyArgsInstance() {
+ return new compact_args();
+ }
+
+ protected boolean isOneway() {
+ return false;
+ }
+
+ public compact_result getResult(I iface, compact_args args) throws org.apache.thrift.TException {
+ compact_result result = new compact_result();
+ iface.compact(args.rqst);
+ return result;
+ }
+ }
+
+ public static class show_compact<I extends Iface> extends org.apache.thrift.ProcessFunction<I, show_compact_args> {
+ public show_compact() {
+ super("show_compact");
+ }
+
+ public show_compact_args getEmptyArgsInstance() {
+ return new show_compact_args();
+ }
+
+ protected boolean isOneway() {
+ return false;
+ }
+
+ public show_compact_result getResult(I iface, show_compact_args args) throws org.apache.thrift.TException {
+ show_compact_result result = new show_compact_result();
+ result.success = iface.show_compact(args.rqst);
+ return result;
+ }
+ }
+
+ }
+
+ public static class create_database_args implements org.apache.thrift.TBase<create_database_args, create_database_args._Fields>, java.io.Serializable, Cloneable {
+ private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("create_database_args");
+
+ private static final org.apache.thrift.protocol.TField DATABASE_FIELD_DESC = new org.apache.thrift.protocol.TField("database", 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 create_database_argsStandardSchemeFactory());
+ schemes.put(TupleScheme.class, new create_database_argsTupleSchemeFactory());
+ }
+
+ private Database database; // 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 {
+ DATABASE((short)1, "database");
+
+ 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: // DATABASE
+ return DATABASE;
+ 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;
}
}
@@ -12930,13 +13944,13 @@ public class ThriftHiveMetastore {
case 0: // SUCCESS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list362 = iprot.readListBegin();
- struct.success = new ArrayList<String>(_list362.size);
- for (int _i363 = 0; _i363 < _list362.size; ++_i363)
+ org.apache.thrift.protocol.TList _list410 = iprot.readListBegin();
+ struct.success = new ArrayList<String>(_list410.size);
+ for (int _i411 = 0; _i411 < _list410.size; ++_i411)
{
- String _elem364; // optional
- _elem364 = iprot.readString();
- struct.success.add(_elem364);
+ String _elem412; // required
+ _elem412 = iprot.readString();
+ struct.success.add(_elem412);
}
iprot.readListEnd();
}
@@ -12971,9 +13985,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 _iter365 : struct.success)
+ for (String _iter413 : struct.success)
{
- oprot.writeString(_iter365);
+ oprot.writeString(_iter413);
}
oprot.writeListEnd();
}
@@ -13012,9 +14026,9 @@ public class ThriftHiveMetastore {
if (struct.isSetSuccess()) {
{
oprot.writeI32(struct.success.size());
- for (String _iter366 : struct.success)
+ for (String _iter414 : struct.success)
{
- oprot.writeString(_iter366);
+ oprot.writeString(_iter414);
}
}
}
@@ -13029,13 +14043,13 @@ public class ThriftHiveMetastore {
BitSet incoming = iprot.readBitSet(2);
if (incoming.get(0)) {
{
- 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)
+ org.apache.thrift.protocol.TList _list415 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+ struct.success = new ArrayList<String>(_list415.size);
+ for (int _i416 = 0; _i416 < _list415.size; ++_i416)
{
- String _elem369; // optional
- _elem369 = iprot.readString();
- struct.success.add(_elem369);
+ String _elem417; // required
+ _elem417 = iprot.readString();
+ struct.success.add(_elem417);
}
}
struct.setSuccessIsSet(true);
@@ -13692,13 +14706,13 @@ public class ThriftHiveMetastore {
case 0: // SUCCESS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list370 = iprot.readListBegin();
- struct.success = new ArrayList<String>(_list370.size);
- for (int _i371 = 0; _i371 < _list370.size; ++_i371)
+ org.apache.thrift.protocol.TList _list418 = iprot.readListBegin();
+ struct.success = new ArrayList<String>(_list418.size);
+ for (int _i419 = 0; _i419 < _list418.size; ++_i419)
{
- String _elem372; // optional
- _elem372 = iprot.readString();
- struct.success.add(_elem372);
+ String _elem420; // required
+ _elem420 = iprot.readString();
+ struct.success.add(_elem420);
}
iprot.readListEnd();
}
@@ -13733,9 +14747,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 _iter373 : struct.success)
+ for (String _iter421 : struct.success)
{
- oprot.writeString(_iter373);
+ oprot.writeString(_iter421);
}
oprot.writeListEnd();
}
@@ -13774,9 +14788,9 @@ public class ThriftHiveMetastore {
if (struct.isSetSuccess()) {
{
oprot.writeI32(struct.success.size());
- for (String _iter374 : struct.success)
+ for (String _iter422 : struct.success)
{
- oprot.writeString(_iter374);
+ oprot.writeString(_iter422);
}
}
}
@@ -13791,13 +14805,13 @@ public class ThriftHiveMetastore {
BitSet incoming = iprot.readBitSet(2);
if (incoming.get(0)) {
{
- org.apache.thrift.protocol.TList _list375 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
- struct.success = new ArrayList<String>(_list375.size);
- for (int _i376 = 0; _i376 < _list375.size; ++_i376)
+ org.apache.thrift.protocol.TList _list423 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+ struct.success = new ArrayList<String>(_list423.size);
+ for (int _i424 = 0; _i424 < _list423.size; ++_i424)
{
- String _elem377; // optional
- _elem377 = iprot.readString();
- struct.success.add(_elem377);
+ String _elem425; // required
+ _elem425 = iprot.readString();
+ struct.success.add(_elem425);
}
}
struct.setSuccessIsSet(true);
@@ -18404,16 +19418,16 @@ public class ThriftHiveMetastore {
case 0: // SUCCESS
if (schemeField.type == org.apache.thrift.protocol.TType.MAP) {
{
- org.apache.thrift.protocol.TMap _map378 = iprot.readMapBegin();
- struct.success = new HashMap<String,Type>(2*_map378.size);
- for (int _i379 = 0; _i379 < _map378.size; ++_i379)
+ org.apache.thrift.protocol.TMap _map426 = iprot.readMapBegin();
+ struct.success = new HashMap<String,Type>(2*_map426.size);
+ for (int _i427 = 0; _i427 < _map426.size; ++_i427)
{
- String _key380; // required
- Type _val381; // required
- _key380 = iprot.readString();
- _val381 = new Type();
- _val381.read(iprot);
- struct.success.put(_key380, _val381);
+ String _key428; // required
+ Type _val429; // required
+ _key428 = iprot.readString();
+ _val429 = new Type();
+ _val429.read(iprot);
+ struct.success.put(_key428, _val429);
}
iprot.readMapEnd();
}
@@ -18448,10 +19462,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> _iter382 : struct.success.entrySet())
+ for (Map.Entry<String, Type> _iter430 : struct.success.entrySet())
{
- oprot.writeString(_iter382.getKey());
- _iter382.getValue().write(oprot);
+ oprot.writeString(_iter430.getKey());
+ _iter430.getValue().write(oprot);
}
oprot.writeMapEnd();
}
@@ -18490,10 +19504,10 @@ public class ThriftHiveMetastore {
if (struct.isSetSuccess()) {
{
oprot.writeI32(struct.success.size());
- for (Map.Entry<String, Type> _iter383 : struct.success.entrySet())
+ for (Map.Entry<String, Type> _iter431 : struct.success.entrySet())
{
- oprot.writeString(_iter383.getKey());
- _iter383.getValue().write(oprot);
+ oprot.writeString(_iter431.getKey());
+ _iter431.getValue().write(oprot);
}
}
}
@@ -18508,16 +19522,16 @@ public class ThriftHiveMetastore {
BitSet incoming = iprot.readBitSet(2);
if (incoming.get(0)) {
{
- org.apache.thrift.protocol.TMap _map384 = 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*_map384.size);
- for (int _i385 = 0; _i385 < _map384.size; ++_i385)
+ org.apache.thrift.protocol.TMap _map432 = 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*_map432.size);
+ for (int _i433 = 0; _i433 < _map432.size; ++_i433)
{
- String _key386; // required
- Type _val387; // required
- _key386 = iprot.readString();
- _val387 = new Type();
- _val387.read(iprot);
- struct.success.put(_key386, _val387);
+ String _key434; // required
+ Type _val435; // required
+ _key434 = iprot.readString();
+ _val435 = new Type();
+ _val435.read(iprot);
+ struct.success.put(_key434, _val435);
}
}
struct.setSuccessIsSet(true);
@@ -19552,14 +20566,14 @@ public class ThriftHiveMetastore {
case 0: // SUCCESS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list388 = iprot.readListBegin();
- struct.success = new ArrayList<FieldSchema>(_list388.size);
- for (int _i389 = 0; _i389 < _list388.size; ++_i389)
+ org.apache.thrift.protocol.TList _list436 = iprot.readListBegin();
+ struct.success = new ArrayList<FieldSchema>(_list436.size);
+ for (int _i437 = 0; _i437 < _list436.size; ++_i437)
{
- FieldSchema _elem390; // optional
- _elem390 = new FieldSchema();
- _elem390.read(iprot);
- struct.success.add(_elem390);
+ FieldSchema _elem438; // required
+ _elem438 = new FieldSchema();
+ _elem438.read(iprot);
+ struct.success.add(_elem438);
}
iprot.readListEnd();
}
@@ -19612,9 +20626,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 _iter391 : struct.success)
+ for (FieldSchema _iter439 : struct.success)
{
- _iter391.write(oprot);
+ _iter439.write(oprot);
}
oprot.writeListEnd();
}
@@ -19669,9 +20683,9 @@ public class ThriftHiveMetastore {
if (struct.isSetSuccess()) {
{
oprot.writeI32(struct.success.size());
- for (FieldSchema _iter392 : struct.success)
+ for (FieldSchema _iter440 : struct.success)
{
- _iter392.write(oprot);
+ _iter440.write(oprot);
}
}
}
@@ -19692,14 +20706,14 @@ public class ThriftHiveMetastore {
BitSet incoming = iprot.readBitSet(4);
if (incoming.get(0)) {
{
- 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)
+ org.apache.thrift.protocol.TList _list441 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.success = new ArrayList<FieldSchema>(_list441.size);
+ for (int _i442 = 0; _i442 < _list441.size; ++_i442)
{
- FieldSchema _elem395; // optional
- _elem395 = new FieldSchema();
- _elem395.read(iprot);
- struct.success.add(_elem395);
+ FieldSchema _elem443; // required
+ _elem443 = new FieldSchema();
+ _elem443.read(iprot);
+ struct.success.add(_elem443);
}
}
struct.setSuccessIsSet(true);
@@ -20744,14 +21758,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<FieldSchema>(_list396.size);
- for (int _i397 = 0; _i397 < _list396.size; ++_i397)
+ org.apache.thrift.protocol.TList _list444 = iprot.readListBegin();
+ struct.success = new ArrayList<FieldSchema>(_list444.size);
+ for (int _i445 = 0; _i445 < _list444.size; ++_i445)
{
- FieldSchema _elem398; // optional
- _elem398 = new FieldSchema();
- _elem398.read(iprot);
- struct.success.add(_elem398);
+ FieldSchema _elem446; // required
+ _elem446 = new FieldSchema();
+ _elem446.read(iprot);
+ struct.success.add(_elem446);
}
iprot.readListEnd();
}
@@ -20804,9 +21818,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 _iter399 : struct.success)
+ for (FieldSchema _iter447 : struct.success)
{
- _iter399.write(oprot);
+ _iter447.write(oprot);
}
oprot.writeListEnd();
}
@@ -20861,9 +21875,9 @@ public class ThriftHiveMetastore {
if (struct.isSetSuccess()) {
{
oprot.writeI32(struct.success.size());
- for (FieldSchema _iter400 : struct.success)
+ for (FieldSchema _iter448 : struct.success)
{
- _iter400.write(oprot);
+ _iter448.write(oprot);
}
}
}
@@ -20884,14 +21898,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<FieldSchema>(_list401.size);
- for (int _i402 = 0; _i402 < _list401.size; ++_i402)
+ org.apache.thrift.protocol.TList _list449 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.success = new ArrayList<FieldSchema>(_list449.size);
+ for (int _i450 = 0; _i450 < _list449.size; ++_i450)
{
- FieldSchema _elem403; // optional
- _elem403 = new FieldSchema();
- _elem403.read(iprot);
- struct.success.add(_elem403);
+ FieldSchema _elem451; // required
+ _elem451 = new FieldSchema();
+ _elem451.read(iprot);
+ struct.success.add(_elem451);
}
}
struct.setSuccessIsSet(true);
@@ -26134,13 +27148,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 _list452 = iprot.readListBegin();
+ struct.success = new ArrayList<String>(_list452.size);
+ for (int _i453 = 0; _i453 < _list452.size; ++_i453)
{
- String _elem406; // optional
- _elem406 = iprot.readString();
- struct.success.add(_elem406);
+ String _elem454; // required
+ _elem454 = iprot.readString();
+ struct.success.add(_elem454);
}
iprot.readListEnd();
}
@@ -26175,9 +27189,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 _iter455 : struct.success)
{
- oprot.writeString(_iter407);
+ oprot.writeString(_iter455);
}
oprot.writeListEnd();
}
@@ -26216,9 +27230,9 @@ public class ThriftHiveMetastore {
if (struct.isSetSuccess()) {
{
oprot.writeI32(struct.success.size());
- for (String _iter408 : struct.success)
+ for (String _iter456 : struct.success)
{
- oprot.writeString(_iter408);
+ oprot.writeString(_iter456);
}
}
}
@@ -26233,13 +27247,13 @@ public class ThriftHiveMetastore {
BitSet incoming = iprot.readBitSet(2);
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 _list457 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+ struct.success = new ArrayList<String>(_list457.size);
+ for (int _i458 = 0; _i458 < _list457.size; ++_i458)
{
- String _elem411; // optional
- _elem411 = iprot.readString();
- struct.success.add(_elem411);
+ String _elem459; // required
+ _elem459 = iprot.readString();
+ struct.success.add(_elem459);
}
}
struct.setSuccessIsSet(true);
@@ -27008,13 +28022,13 @@ public class ThriftHiveMetastore {
case 0: // SUCCESS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list412 = iprot.readListBegin();
- struct.success = new ArrayList<String>(_list412.size);
- for (int _i413 = 0; _i413 < _list412.size; ++_i413)
+ org.apache.thrift.protocol.TList _list460 = iprot.readListBegin();
+ struct.success = new ArrayList<String>(_list460.size);
+ for (int _i461 = 0; _i461 < _list460.size; ++_i461)
{
- String _elem414; // optional
- _elem414 = iprot.readString();
- struct.success.add(_elem414);
+ String _elem462; // required
+ _elem462 = iprot.readString();
+ struct.success.add(_elem462);
}
iprot.readListEnd();
}
@@ -27049,9 +28063,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 _iter415 : struct.success)
+ for (String _iter463 : struct.success)
{
- oprot.writeString(_iter415);
+ oprot.writeString(_iter463);
}
oprot.writeListEnd();
}
@@ -27090,9 +28104,9 @@ public class ThriftHiveMetastore {
if (struct.isSetSuccess()) {
{
oprot.writeI32(struct.success.size());
- for (String _iter416 : struct.success)
+ for (String _iter464 : struct.success)
{
- oprot.writeString(_iter416);
+ oprot.writeString(_iter464);
}
}
}
@@ -27107,13 +28121,13 @@ public class ThriftHiveMetastore {
BitSet incoming = iprot.readBitSet(2);
if (incoming.get(0)) {
{
- org.apache.thrift.protocol.TList _list417 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
- struct.success = new ArrayList<String>(_list417.size);
- for (int _i418 = 0; _i418 < _list417.size; ++_i418)
+ org.apache.thrift.protocol.TList _list465 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+ struct.success = new ArrayList<String>(_list465.size);
+ for (int _i466 = 0; _i466 < _list465.size; ++_i466)
{
- String _elem419; // optional
- _elem419 = iprot.readString();
- struct.success.add(_elem419);
+ String _elem467; // required
+ _elem467 = iprot.readString();
+ struct.success.add(_elem467);
}
}
struct.setSuccessIsSet(true);
@@ -28569,13 +29583,13 @@ public class ThriftHiveMetastore {
case 2: // TBL_NAMES
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list420 = iprot.readListBegin();
- struct.tbl_names = new ArrayList<String>(_list420.size);
- for (int _i421 = 0; _i421 < _list420.size; ++_i421)
+ org.apache.thrift.protocol.TList _list468 = iprot.readListBegin();
+ struct.tbl_names = new ArrayList<String>(_list468.size);
+ for (int _i469 = 0; _i469 < _list468.size; ++_i469)
{
- String _elem422; // optional
- _elem422 = iprot.readString();
- struct.tbl_names.add(_elem422);
+ String _elem470; // required
+ _elem470 = iprot.readString();
+ struct.tbl_names.add(_elem470);
}
iprot.readListEnd();
}
@@ -28606,9 +29620,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 _iter423 : struct.tbl_names)
+ for (String _iter471 : struct.tbl_names)
{
- oprot.writeString(_iter423);
+ oprot.writeString(_iter471);
}
oprot.writeListEnd();
}
@@ -28645,9 +29659,9 @@ public class ThriftHiveMetastore {
if (struct.isSetTbl_names()) {
{
oprot.writeI32(struct.tbl_names.size());
- for (String _iter424 : struct.tbl_names)
+ for (String _iter472 : struct.tbl_names)
{
- oprot.writeString(_iter424);
+ oprot.writeString(_iter472);
}
}
}
@@ -28663,13 +29677,13 @@ public class ThriftHiveMetastore {
}
if (incoming.get(1)) {
{
- org.apache.thrift.protocol.TList _list425 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
- struct.tbl_names = new ArrayList<String>(_list425.size);
- for (int _i426 = 0; _i426 < _list425.size; ++_i426)
+ org.apache.thrift.protocol.TList _list473 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+ struct.tbl_names = new ArrayList<String>(_list473.size);
+ for (int _i474 = 0; _i474 < _list473.size; ++_i474)
{
- String _elem427; // optional
- _elem427 = iprot.readString();
- struct.tbl_names.add(_elem427);
+ String _elem475; // required
+ _elem475 = iprot.readString();
+ struct.tbl_names.add(_elem475);
}
}
struct.setTbl_namesIsSet(true);
@@ -29237,14 +30251,14 @@ public class ThriftHiveMetastore {
case 0: // SUCCESS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list428 = iprot.readListBegin();
- struct.success = new ArrayList<Table>(_list428.size);
- for (int _i429 = 0; _i429 < _list428.size; ++_i429)
+ org.apache.thrift.protocol.TList _list476 = iprot.readListBegin();
+ struct.success = new ArrayList<Table>(_list476.size);
+ for (int _i477 = 0; _i477 < _list476.size; ++_i477)
{
- Table _elem430; // optional
- _elem430 = new Table();
- _elem430.read(iprot);
- struct.success.add(_elem430);
+ Table _elem478; // required
+ _elem478 = new Table();
+ _elem478.read(iprot);
+ struct.success.add(_elem478);
}
iprot.readListEnd();
}
@@ -29297,9 +30311,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 _iter431 : struct.success)
+ for (Table _iter479 : struct.success)
{
- _iter431.write(oprot);
+ _iter479.write(oprot);
}
oprot.writeListEnd();
}
@@ -29354,9 +30368,9 @@ public class ThriftHiveMetastore {
if (struct.isSetSuccess()) {
{
oprot.writeI32(struct.success.size());
- for (Table _iter432 : struct.success)
+ for (Table _iter480 : struct.success)
{
- _iter432.write(oprot);
+ _iter480.write(oprot);
}
}
}
@@ -29377,14 +30391,14 @@ public class ThriftHiveMetastore {
BitSet incoming = iprot.readBitSet(4);
if (incoming.get(0)) {
{
- org.apache.thrift.protocol.TList _list433 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.success = new ArrayList<Table>(_list433.size);
- for (int _i434 = 0; _i434 < _list433.size; ++_i434)
+ org.apache.thrift.protocol.TList _list481 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.success = new ArrayList<Table>(_list481.size);
+ for (int _i482 = 0; _i482 < _list481.size; ++_i482)
{
- Table _elem435; // optional
- _elem435 = new Table();
- _elem435.read(iprot);
- struct.success.add(_elem435);
+ Table _elem483; // required
+ _elem483 = new Table();
+ _elem483.read(iprot);
+ struct.success.add(_elem483);
}
}
struct.setSuccessIsSet(true);
@@ -30533,13 +31547,13 @@ public class ThriftHiveMetastore {
case 0: // SUCCESS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list436 = iprot.readListBegin();
- struct.success = new ArrayList<String>(_list436.size);
- for (int _i437 = 0; _i437 < _list436.size; ++_i437)
+ org.apache.thrift.protocol.TList _list484 = iprot.readListBegin();
+ struct.success = new ArrayList<String>(_list484.size);
+ for (int _i485 = 0; _i485 < _list484.size; ++_i485)
{
- String _elem438; // optional
- _elem438 = iprot.readString();
- struct.success.add(_elem438);
+ String _elem486; // required
+ _elem486 = iprot.readString();
+ struct.success.add(_elem486);
}
iprot.readListEnd();
}
@@ -30592,9 +31606,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 _iter439 : struct.success)
+ for (String _iter487 : struct.success)
{
- oprot.writeString(_iter439);
+ oprot.writeString(_iter487);
}
oprot.writeListEnd();
}
@@ -30649,9 +31663,9 @@ public class ThriftHiveMetastore {
if (struct.isSetSuccess()) {
{
oprot.writeI32(struct.success.size());
- for (String _iter440 : struct.success)
+ for (String _iter488 : struct.success)
{
- oprot.writeString(_iter440);
+ oprot.writeString(_iter488);
}
}
}
@@ -30672,13 +31686,13 @@ public class ThriftHiveMetastore {
BitSet incoming = iprot.readBitSet(4);
if (incoming.get(0)) {
{
- org.apache.thrift.protocol.TList _list441 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
- struct.success = new ArrayList<String>(_list441.size);
- for (int _i442 = 0; _i442 < _list441.size; ++_i442)
+ org.apache.thrift.protocol.TList _list489 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+ struct.success = new ArrayList<String>(_list489.size);
+ for (int _i490 = 0; _i490 < _list489.size; ++_i490)
{
- String _elem443; // optional
- _elem443 = iprot.readString();
- struct.success.add(_elem443);
+ String _elem491; // required
+ _elem491 = iprot.readString();
+ struct.success.add(_elem491);
}
}
struct.setSuccessIsSet(true);
@@ -35398,14 +36412,14 @@ public class ThriftHiveMetastore {
case 1: // NEW_PARTS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list444 = iprot.readListBegin();
- struct.new_parts = new ArrayList<Partition>(_list444.size);
- for (int _i445 = 0; _i445 < _list444.size; ++_i445)
+ org.apache.thrift.protocol.TList _list492 = iprot.readListBegin();
+ struct.new_parts = new ArrayList<Partition>(_list492.size);
+ for (int _i493 = 0; _i493 < _list492.size; ++_i493)
{
- Partition _elem446; // optional
- _elem446 = new Partition();
- _elem446.read(iprot);
- struct.new_parts.add(_elem446);
+ Partition _elem494; // required
+ _elem494 = new Partition();
+ _elem494.read(iprot);
+ struct.new_parts.add(_elem494);
}
iprot.readListEnd();
}
@@ -35431,9 +36445,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 _iter447 : struct.new_parts)
+ for (Partition _iter495 : struct.new_parts)
{
- _iter447.write(oprot);
+ _iter495.write(oprot);
}
oprot.writeListEnd();
}
@@ -35464,9 +36478,9 @@ public class ThriftHiveMetastore {
if (struct.isSetNew_parts()) {
{
oprot.writeI32(struct.new_parts.size());
- for (Partition _iter448 : struct.new_parts)
+ for (Partition _iter496 : struct.new_parts)
{
- _iter448.write(oprot);
+ _iter496.write(oprot);
}
}
}
@@ -35478,14 +36492,14 @@ public class ThriftHiveMetastore {
BitSet incoming = iprot.readBitSet(1);
if (incoming.get(0)) {
{
- org.apache.thrift.protocol.TList _list449 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.new_parts = new ArrayList<Partition>(_list449.size);
- for (int _i450 = 0; _i450 < _list449.size; ++_i450)
+ org.apache.thrift.protocol.TList _list497 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.new_parts = new ArrayList<Partition>(_list497.size);
+ for (int _i498 = 0; _i498 < _list497.size; ++_i498)
{
- Partition _elem451; // optional
- _elem451 = new Partition();
- _elem451.read(iprot);
- struct.new_parts.add(_elem451);
+ Partition _elem499; // required
+ _elem499 = new Partition();
+ _elem499.read(iprot);
+ struct.new_parts.add(_elem499);
}
}
struct.setNew_partsIsSet(true);
@@ -36664,13 +37678,13 @@ public class ThriftHiveMetastore {
case 3: // PART_VALS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list452 = iprot.readListBegin();
- struct.part_vals = new ArrayList<String>(_list452.size);
- for (int _i453 = 0; _i453 < _list452.size; ++_i453)
+ org.apache.thrift.protocol.TList _list500 = iprot.readListBegin();
+ struct.part_vals = new ArrayList<String>(_list500.size);
+ for (int _i501 = 0; _i501 < _list500.size; ++_i501)
{
- String _elem454; // optional
- _elem454 = iprot.readString();
- struct.part_vals.add(_elem454);
+ String _elem502; // required
+ _elem502 = iprot.readString();
[... 11813 lines stripped ...]