You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hive.apache.org by vg...@apache.org on 2016/01/08 01:19:53 UTC
[43/51] [partial] hive git commit: HIVE-12442: Refactor/repackage
HiveServer2's Thrift code so that it can be used in the tasks (Rohit Dholakia
reviewed by Vaibhav Gumashta)
http://git-wip-us.apache.org/repos/asf/hive/blob/2542f5cc/service-rpc/src/gen/thrift/gen-javabean/org/apache/hive/service/rpc/thrift/TCLIService.java
----------------------------------------------------------------------
diff --git a/service-rpc/src/gen/thrift/gen-javabean/org/apache/hive/service/rpc/thrift/TCLIService.java b/service-rpc/src/gen/thrift/gen-javabean/org/apache/hive/service/rpc/thrift/TCLIService.java
new file mode 100644
index 0000000..a8cb89e
--- /dev/null
+++ b/service-rpc/src/gen/thrift/gen-javabean/org/apache/hive/service/rpc/thrift/TCLIService.java
@@ -0,0 +1,16422 @@
+/**
+ * Autogenerated by Thrift Compiler (0.9.2)
+ *
+ * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
+ * @generated
+ */
+package org.apache.hive.service.rpc.thrift;
+
+import org.apache.thrift.scheme.IScheme;
+import org.apache.thrift.scheme.SchemeFactory;
+import org.apache.thrift.scheme.StandardScheme;
+
+import org.apache.thrift.scheme.TupleScheme;
+import org.apache.thrift.protocol.TTupleProtocol;
+import org.apache.thrift.protocol.TProtocolException;
+import org.apache.thrift.EncodingUtils;
+import org.apache.thrift.TException;
+import org.apache.thrift.async.AsyncMethodCallback;
+import org.apache.thrift.server.AbstractNonblockingServer.*;
+import java.util.List;
+import java.util.ArrayList;
+import java.util.Map;
+import java.util.HashMap;
+import java.util.EnumMap;
+import java.util.Set;
+import java.util.HashSet;
+import java.util.EnumSet;
+import java.util.Collections;
+import java.util.BitSet;
+import java.nio.ByteBuffer;
+import java.util.Arrays;
+import javax.annotation.Generated;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"})
+@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-12-14")
+public class TCLIService {
+
+ public interface Iface {
+
+ public TOpenSessionResp OpenSession(TOpenSessionReq req) throws org.apache.thrift.TException;
+
+ public TCloseSessionResp CloseSession(TCloseSessionReq req) throws org.apache.thrift.TException;
+
+ public TGetInfoResp GetInfo(TGetInfoReq req) throws org.apache.thrift.TException;
+
+ public TExecuteStatementResp ExecuteStatement(TExecuteStatementReq req) throws org.apache.thrift.TException;
+
+ public TGetTypeInfoResp GetTypeInfo(TGetTypeInfoReq req) throws org.apache.thrift.TException;
+
+ public TGetCatalogsResp GetCatalogs(TGetCatalogsReq req) throws org.apache.thrift.TException;
+
+ public TGetSchemasResp GetSchemas(TGetSchemasReq req) throws org.apache.thrift.TException;
+
+ public TGetTablesResp GetTables(TGetTablesReq req) throws org.apache.thrift.TException;
+
+ public TGetTableTypesResp GetTableTypes(TGetTableTypesReq req) throws org.apache.thrift.TException;
+
+ public TGetColumnsResp GetColumns(TGetColumnsReq req) throws org.apache.thrift.TException;
+
+ public TGetFunctionsResp GetFunctions(TGetFunctionsReq req) throws org.apache.thrift.TException;
+
+ public TGetOperationStatusResp GetOperationStatus(TGetOperationStatusReq req) throws org.apache.thrift.TException;
+
+ public TCancelOperationResp CancelOperation(TCancelOperationReq req) throws org.apache.thrift.TException;
+
+ public TCloseOperationResp CloseOperation(TCloseOperationReq req) throws org.apache.thrift.TException;
+
+ public TGetResultSetMetadataResp GetResultSetMetadata(TGetResultSetMetadataReq req) throws org.apache.thrift.TException;
+
+ public TFetchResultsResp FetchResults(TFetchResultsReq req) throws org.apache.thrift.TException;
+
+ public TGetDelegationTokenResp GetDelegationToken(TGetDelegationTokenReq req) throws org.apache.thrift.TException;
+
+ public TCancelDelegationTokenResp CancelDelegationToken(TCancelDelegationTokenReq req) throws org.apache.thrift.TException;
+
+ public TRenewDelegationTokenResp RenewDelegationToken(TRenewDelegationTokenReq req) throws org.apache.thrift.TException;
+
+ }
+
+ public interface AsyncIface {
+
+ public void OpenSession(TOpenSessionReq req, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
+
+ public void CloseSession(TCloseSessionReq req, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
+
+ public void GetInfo(TGetInfoReq req, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
+
+ public void ExecuteStatement(TExecuteStatementReq req, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
+
+ public void GetTypeInfo(TGetTypeInfoReq req, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
+
+ public void GetCatalogs(TGetCatalogsReq req, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
+
+ public void GetSchemas(TGetSchemasReq req, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
+
+ public void GetTables(TGetTablesReq req, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
+
+ public void GetTableTypes(TGetTableTypesReq req, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
+
+ public void GetColumns(TGetColumnsReq req, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
+
+ public void GetFunctions(TGetFunctionsReq req, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
+
+ public void GetOperationStatus(TGetOperationStatusReq req, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
+
+ public void CancelOperation(TCancelOperationReq req, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
+
+ public void CloseOperation(TCloseOperationReq req, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
+
+ public void GetResultSetMetadata(TGetResultSetMetadataReq req, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
+
+ public void FetchResults(TFetchResultsReq req, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
+
+ public void GetDelegationToken(TGetDelegationTokenReq req, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
+
+ public void CancelDelegationToken(TCancelDelegationTokenReq req, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
+
+ public void RenewDelegationToken(TRenewDelegationTokenReq req, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
+
+ }
+
+ public static class Client extends org.apache.thrift.TServiceClient implements Iface {
+ public static class Factory implements org.apache.thrift.TServiceClientFactory<Client> {
+ public Factory() {}
+ public Client getClient(org.apache.thrift.protocol.TProtocol prot) {
+ return new Client(prot);
+ }
+ public Client getClient(org.apache.thrift.protocol.TProtocol iprot, org.apache.thrift.protocol.TProtocol oprot) {
+ return new Client(iprot, oprot);
+ }
+ }
+
+ public Client(org.apache.thrift.protocol.TProtocol prot)
+ {
+ super(prot, prot);
+ }
+
+ public Client(org.apache.thrift.protocol.TProtocol iprot, org.apache.thrift.protocol.TProtocol oprot) {
+ super(iprot, oprot);
+ }
+
+ public TOpenSessionResp OpenSession(TOpenSessionReq req) throws org.apache.thrift.TException
+ {
+ send_OpenSession(req);
+ return recv_OpenSession();
+ }
+
+ public void send_OpenSession(TOpenSessionReq req) throws org.apache.thrift.TException
+ {
+ OpenSession_args args = new OpenSession_args();
+ args.setReq(req);
+ sendBase("OpenSession", args);
+ }
+
+ public TOpenSessionResp recv_OpenSession() throws org.apache.thrift.TException
+ {
+ OpenSession_result result = new OpenSession_result();
+ receiveBase(result, "OpenSession");
+ if (result.isSetSuccess()) {
+ return result.success;
+ }
+ throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "OpenSession failed: unknown result");
+ }
+
+ public TCloseSessionResp CloseSession(TCloseSessionReq req) throws org.apache.thrift.TException
+ {
+ send_CloseSession(req);
+ return recv_CloseSession();
+ }
+
+ public void send_CloseSession(TCloseSessionReq req) throws org.apache.thrift.TException
+ {
+ CloseSession_args args = new CloseSession_args();
+ args.setReq(req);
+ sendBase("CloseSession", args);
+ }
+
+ public TCloseSessionResp recv_CloseSession() throws org.apache.thrift.TException
+ {
+ CloseSession_result result = new CloseSession_result();
+ receiveBase(result, "CloseSession");
+ if (result.isSetSuccess()) {
+ return result.success;
+ }
+ throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "CloseSession failed: unknown result");
+ }
+
+ public TGetInfoResp GetInfo(TGetInfoReq req) throws org.apache.thrift.TException
+ {
+ send_GetInfo(req);
+ return recv_GetInfo();
+ }
+
+ public void send_GetInfo(TGetInfoReq req) throws org.apache.thrift.TException
+ {
+ GetInfo_args args = new GetInfo_args();
+ args.setReq(req);
+ sendBase("GetInfo", args);
+ }
+
+ public TGetInfoResp recv_GetInfo() throws org.apache.thrift.TException
+ {
+ GetInfo_result result = new GetInfo_result();
+ receiveBase(result, "GetInfo");
+ if (result.isSetSuccess()) {
+ return result.success;
+ }
+ throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "GetInfo failed: unknown result");
+ }
+
+ public TExecuteStatementResp ExecuteStatement(TExecuteStatementReq req) throws org.apache.thrift.TException
+ {
+ send_ExecuteStatement(req);
+ return recv_ExecuteStatement();
+ }
+
+ public void send_ExecuteStatement(TExecuteStatementReq req) throws org.apache.thrift.TException
+ {
+ ExecuteStatement_args args = new ExecuteStatement_args();
+ args.setReq(req);
+ sendBase("ExecuteStatement", args);
+ }
+
+ public TExecuteStatementResp recv_ExecuteStatement() throws org.apache.thrift.TException
+ {
+ ExecuteStatement_result result = new ExecuteStatement_result();
+ receiveBase(result, "ExecuteStatement");
+ if (result.isSetSuccess()) {
+ return result.success;
+ }
+ throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "ExecuteStatement failed: unknown result");
+ }
+
+ public TGetTypeInfoResp GetTypeInfo(TGetTypeInfoReq req) throws org.apache.thrift.TException
+ {
+ send_GetTypeInfo(req);
+ return recv_GetTypeInfo();
+ }
+
+ public void send_GetTypeInfo(TGetTypeInfoReq req) throws org.apache.thrift.TException
+ {
+ GetTypeInfo_args args = new GetTypeInfo_args();
+ args.setReq(req);
+ sendBase("GetTypeInfo", args);
+ }
+
+ public TGetTypeInfoResp recv_GetTypeInfo() throws org.apache.thrift.TException
+ {
+ GetTypeInfo_result result = new GetTypeInfo_result();
+ receiveBase(result, "GetTypeInfo");
+ if (result.isSetSuccess()) {
+ return result.success;
+ }
+ throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "GetTypeInfo failed: unknown result");
+ }
+
+ public TGetCatalogsResp GetCatalogs(TGetCatalogsReq req) throws org.apache.thrift.TException
+ {
+ send_GetCatalogs(req);
+ return recv_GetCatalogs();
+ }
+
+ public void send_GetCatalogs(TGetCatalogsReq req) throws org.apache.thrift.TException
+ {
+ GetCatalogs_args args = new GetCatalogs_args();
+ args.setReq(req);
+ sendBase("GetCatalogs", args);
+ }
+
+ public TGetCatalogsResp recv_GetCatalogs() throws org.apache.thrift.TException
+ {
+ GetCatalogs_result result = new GetCatalogs_result();
+ receiveBase(result, "GetCatalogs");
+ if (result.isSetSuccess()) {
+ return result.success;
+ }
+ throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "GetCatalogs failed: unknown result");
+ }
+
+ public TGetSchemasResp GetSchemas(TGetSchemasReq req) throws org.apache.thrift.TException
+ {
+ send_GetSchemas(req);
+ return recv_GetSchemas();
+ }
+
+ public void send_GetSchemas(TGetSchemasReq req) throws org.apache.thrift.TException
+ {
+ GetSchemas_args args = new GetSchemas_args();
+ args.setReq(req);
+ sendBase("GetSchemas", args);
+ }
+
+ public TGetSchemasResp recv_GetSchemas() throws org.apache.thrift.TException
+ {
+ GetSchemas_result result = new GetSchemas_result();
+ receiveBase(result, "GetSchemas");
+ if (result.isSetSuccess()) {
+ return result.success;
+ }
+ throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "GetSchemas failed: unknown result");
+ }
+
+ public TGetTablesResp GetTables(TGetTablesReq req) throws org.apache.thrift.TException
+ {
+ send_GetTables(req);
+ return recv_GetTables();
+ }
+
+ public void send_GetTables(TGetTablesReq req) throws org.apache.thrift.TException
+ {
+ GetTables_args args = new GetTables_args();
+ args.setReq(req);
+ sendBase("GetTables", args);
+ }
+
+ public TGetTablesResp recv_GetTables() throws org.apache.thrift.TException
+ {
+ GetTables_result result = new GetTables_result();
+ receiveBase(result, "GetTables");
+ if (result.isSetSuccess()) {
+ return result.success;
+ }
+ throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "GetTables failed: unknown result");
+ }
+
+ public TGetTableTypesResp GetTableTypes(TGetTableTypesReq req) throws org.apache.thrift.TException
+ {
+ send_GetTableTypes(req);
+ return recv_GetTableTypes();
+ }
+
+ public void send_GetTableTypes(TGetTableTypesReq req) throws org.apache.thrift.TException
+ {
+ GetTableTypes_args args = new GetTableTypes_args();
+ args.setReq(req);
+ sendBase("GetTableTypes", args);
+ }
+
+ public TGetTableTypesResp recv_GetTableTypes() throws org.apache.thrift.TException
+ {
+ GetTableTypes_result result = new GetTableTypes_result();
+ receiveBase(result, "GetTableTypes");
+ if (result.isSetSuccess()) {
+ return result.success;
+ }
+ throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "GetTableTypes failed: unknown result");
+ }
+
+ public TGetColumnsResp GetColumns(TGetColumnsReq req) throws org.apache.thrift.TException
+ {
+ send_GetColumns(req);
+ return recv_GetColumns();
+ }
+
+ public void send_GetColumns(TGetColumnsReq req) throws org.apache.thrift.TException
+ {
+ GetColumns_args args = new GetColumns_args();
+ args.setReq(req);
+ sendBase("GetColumns", args);
+ }
+
+ public TGetColumnsResp recv_GetColumns() throws org.apache.thrift.TException
+ {
+ GetColumns_result result = new GetColumns_result();
+ receiveBase(result, "GetColumns");
+ if (result.isSetSuccess()) {
+ return result.success;
+ }
+ throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "GetColumns failed: unknown result");
+ }
+
+ public TGetFunctionsResp GetFunctions(TGetFunctionsReq req) throws org.apache.thrift.TException
+ {
+ send_GetFunctions(req);
+ return recv_GetFunctions();
+ }
+
+ public void send_GetFunctions(TGetFunctionsReq req) throws org.apache.thrift.TException
+ {
+ GetFunctions_args args = new GetFunctions_args();
+ args.setReq(req);
+ sendBase("GetFunctions", args);
+ }
+
+ public TGetFunctionsResp recv_GetFunctions() throws org.apache.thrift.TException
+ {
+ GetFunctions_result result = new GetFunctions_result();
+ receiveBase(result, "GetFunctions");
+ if (result.isSetSuccess()) {
+ return result.success;
+ }
+ throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "GetFunctions failed: unknown result");
+ }
+
+ public TGetOperationStatusResp GetOperationStatus(TGetOperationStatusReq req) throws org.apache.thrift.TException
+ {
+ send_GetOperationStatus(req);
+ return recv_GetOperationStatus();
+ }
+
+ public void send_GetOperationStatus(TGetOperationStatusReq req) throws org.apache.thrift.TException
+ {
+ GetOperationStatus_args args = new GetOperationStatus_args();
+ args.setReq(req);
+ sendBase("GetOperationStatus", args);
+ }
+
+ public TGetOperationStatusResp recv_GetOperationStatus() throws org.apache.thrift.TException
+ {
+ GetOperationStatus_result result = new GetOperationStatus_result();
+ receiveBase(result, "GetOperationStatus");
+ if (result.isSetSuccess()) {
+ return result.success;
+ }
+ throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "GetOperationStatus failed: unknown result");
+ }
+
+ public TCancelOperationResp CancelOperation(TCancelOperationReq req) throws org.apache.thrift.TException
+ {
+ send_CancelOperation(req);
+ return recv_CancelOperation();
+ }
+
+ public void send_CancelOperation(TCancelOperationReq req) throws org.apache.thrift.TException
+ {
+ CancelOperation_args args = new CancelOperation_args();
+ args.setReq(req);
+ sendBase("CancelOperation", args);
+ }
+
+ public TCancelOperationResp recv_CancelOperation() throws org.apache.thrift.TException
+ {
+ CancelOperation_result result = new CancelOperation_result();
+ receiveBase(result, "CancelOperation");
+ if (result.isSetSuccess()) {
+ return result.success;
+ }
+ throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "CancelOperation failed: unknown result");
+ }
+
+ public TCloseOperationResp CloseOperation(TCloseOperationReq req) throws org.apache.thrift.TException
+ {
+ send_CloseOperation(req);
+ return recv_CloseOperation();
+ }
+
+ public void send_CloseOperation(TCloseOperationReq req) throws org.apache.thrift.TException
+ {
+ CloseOperation_args args = new CloseOperation_args();
+ args.setReq(req);
+ sendBase("CloseOperation", args);
+ }
+
+ public TCloseOperationResp recv_CloseOperation() throws org.apache.thrift.TException
+ {
+ CloseOperation_result result = new CloseOperation_result();
+ receiveBase(result, "CloseOperation");
+ if (result.isSetSuccess()) {
+ return result.success;
+ }
+ throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "CloseOperation failed: unknown result");
+ }
+
+ public TGetResultSetMetadataResp GetResultSetMetadata(TGetResultSetMetadataReq req) throws org.apache.thrift.TException
+ {
+ send_GetResultSetMetadata(req);
+ return recv_GetResultSetMetadata();
+ }
+
+ public void send_GetResultSetMetadata(TGetResultSetMetadataReq req) throws org.apache.thrift.TException
+ {
+ GetResultSetMetadata_args args = new GetResultSetMetadata_args();
+ args.setReq(req);
+ sendBase("GetResultSetMetadata", args);
+ }
+
+ public TGetResultSetMetadataResp recv_GetResultSetMetadata() throws org.apache.thrift.TException
+ {
+ GetResultSetMetadata_result result = new GetResultSetMetadata_result();
+ receiveBase(result, "GetResultSetMetadata");
+ if (result.isSetSuccess()) {
+ return result.success;
+ }
+ throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "GetResultSetMetadata failed: unknown result");
+ }
+
+ public TFetchResultsResp FetchResults(TFetchResultsReq req) throws org.apache.thrift.TException
+ {
+ send_FetchResults(req);
+ return recv_FetchResults();
+ }
+
+ public void send_FetchResults(TFetchResultsReq req) throws org.apache.thrift.TException
+ {
+ FetchResults_args args = new FetchResults_args();
+ args.setReq(req);
+ sendBase("FetchResults", args);
+ }
+
+ public TFetchResultsResp recv_FetchResults() throws org.apache.thrift.TException
+ {
+ FetchResults_result result = new FetchResults_result();
+ receiveBase(result, "FetchResults");
+ if (result.isSetSuccess()) {
+ return result.success;
+ }
+ throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "FetchResults failed: unknown result");
+ }
+
+ public TGetDelegationTokenResp GetDelegationToken(TGetDelegationTokenReq req) throws org.apache.thrift.TException
+ {
+ send_GetDelegationToken(req);
+ return recv_GetDelegationToken();
+ }
+
+ public void send_GetDelegationToken(TGetDelegationTokenReq req) throws org.apache.thrift.TException
+ {
+ GetDelegationToken_args args = new GetDelegationToken_args();
+ args.setReq(req);
+ sendBase("GetDelegationToken", args);
+ }
+
+ public TGetDelegationTokenResp recv_GetDelegationToken() throws org.apache.thrift.TException
+ {
+ GetDelegationToken_result result = new GetDelegationToken_result();
+ receiveBase(result, "GetDelegationToken");
+ if (result.isSetSuccess()) {
+ return result.success;
+ }
+ throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "GetDelegationToken failed: unknown result");
+ }
+
+ public TCancelDelegationTokenResp CancelDelegationToken(TCancelDelegationTokenReq req) throws org.apache.thrift.TException
+ {
+ send_CancelDelegationToken(req);
+ return recv_CancelDelegationToken();
+ }
+
+ public void send_CancelDelegationToken(TCancelDelegationTokenReq req) throws org.apache.thrift.TException
+ {
+ CancelDelegationToken_args args = new CancelDelegationToken_args();
+ args.setReq(req);
+ sendBase("CancelDelegationToken", args);
+ }
+
+ public TCancelDelegationTokenResp recv_CancelDelegationToken() throws org.apache.thrift.TException
+ {
+ CancelDelegationToken_result result = new CancelDelegationToken_result();
+ receiveBase(result, "CancelDelegationToken");
+ if (result.isSetSuccess()) {
+ return result.success;
+ }
+ throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "CancelDelegationToken failed: unknown result");
+ }
+
+ public TRenewDelegationTokenResp RenewDelegationToken(TRenewDelegationTokenReq req) throws org.apache.thrift.TException
+ {
+ send_RenewDelegationToken(req);
+ return recv_RenewDelegationToken();
+ }
+
+ public void send_RenewDelegationToken(TRenewDelegationTokenReq req) throws org.apache.thrift.TException
+ {
+ RenewDelegationToken_args args = new RenewDelegationToken_args();
+ args.setReq(req);
+ sendBase("RenewDelegationToken", args);
+ }
+
+ public TRenewDelegationTokenResp recv_RenewDelegationToken() throws org.apache.thrift.TException
+ {
+ RenewDelegationToken_result result = new RenewDelegationToken_result();
+ receiveBase(result, "RenewDelegationToken");
+ if (result.isSetSuccess()) {
+ return result.success;
+ }
+ throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "RenewDelegationToken failed: unknown result");
+ }
+
+ }
+ public static class AsyncClient extends org.apache.thrift.async.TAsyncClient implements AsyncIface {
+ public static class Factory implements org.apache.thrift.async.TAsyncClientFactory<AsyncClient> {
+ private org.apache.thrift.async.TAsyncClientManager clientManager;
+ private org.apache.thrift.protocol.TProtocolFactory protocolFactory;
+ public Factory(org.apache.thrift.async.TAsyncClientManager clientManager, org.apache.thrift.protocol.TProtocolFactory protocolFactory) {
+ this.clientManager = clientManager;
+ this.protocolFactory = protocolFactory;
+ }
+ public AsyncClient getAsyncClient(org.apache.thrift.transport.TNonblockingTransport transport) {
+ return new AsyncClient(protocolFactory, clientManager, transport);
+ }
+ }
+
+ public AsyncClient(org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.async.TAsyncClientManager clientManager, org.apache.thrift.transport.TNonblockingTransport transport) {
+ super(protocolFactory, clientManager, transport);
+ }
+
+ public void OpenSession(TOpenSessionReq req, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException {
+ checkReady();
+ OpenSession_call method_call = new OpenSession_call(req, resultHandler, this, ___protocolFactory, ___transport);
+ this.___currentMethod = method_call;
+ ___manager.call(method_call);
+ }
+
+ public static class OpenSession_call extends org.apache.thrift.async.TAsyncMethodCall {
+ private TOpenSessionReq req;
+ public OpenSession_call(TOpenSessionReq 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("OpenSession", org.apache.thrift.protocol.TMessageType.CALL, 0));
+ OpenSession_args args = new OpenSession_args();
+ args.setReq(req);
+ args.write(prot);
+ prot.writeMessageEnd();
+ }
+
+ public TOpenSessionResp 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_OpenSession();
+ }
+ }
+
+ public void CloseSession(TCloseSessionReq req, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException {
+ checkReady();
+ CloseSession_call method_call = new CloseSession_call(req, resultHandler, this, ___protocolFactory, ___transport);
+ this.___currentMethod = method_call;
+ ___manager.call(method_call);
+ }
+
+ public static class CloseSession_call extends org.apache.thrift.async.TAsyncMethodCall {
+ private TCloseSessionReq req;
+ public CloseSession_call(TCloseSessionReq 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("CloseSession", org.apache.thrift.protocol.TMessageType.CALL, 0));
+ CloseSession_args args = new CloseSession_args();
+ args.setReq(req);
+ args.write(prot);
+ prot.writeMessageEnd();
+ }
+
+ public TCloseSessionResp 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_CloseSession();
+ }
+ }
+
+ public void GetInfo(TGetInfoReq req, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException {
+ checkReady();
+ GetInfo_call method_call = new GetInfo_call(req, resultHandler, this, ___protocolFactory, ___transport);
+ this.___currentMethod = method_call;
+ ___manager.call(method_call);
+ }
+
+ public static class GetInfo_call extends org.apache.thrift.async.TAsyncMethodCall {
+ private TGetInfoReq req;
+ public GetInfo_call(TGetInfoReq 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("GetInfo", org.apache.thrift.protocol.TMessageType.CALL, 0));
+ GetInfo_args args = new GetInfo_args();
+ args.setReq(req);
+ args.write(prot);
+ prot.writeMessageEnd();
+ }
+
+ public TGetInfoResp 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_GetInfo();
+ }
+ }
+
+ public void ExecuteStatement(TExecuteStatementReq req, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException {
+ checkReady();
+ ExecuteStatement_call method_call = new ExecuteStatement_call(req, resultHandler, this, ___protocolFactory, ___transport);
+ this.___currentMethod = method_call;
+ ___manager.call(method_call);
+ }
+
+ public static class ExecuteStatement_call extends org.apache.thrift.async.TAsyncMethodCall {
+ private TExecuteStatementReq req;
+ public ExecuteStatement_call(TExecuteStatementReq 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("ExecuteStatement", org.apache.thrift.protocol.TMessageType.CALL, 0));
+ ExecuteStatement_args args = new ExecuteStatement_args();
+ args.setReq(req);
+ args.write(prot);
+ prot.writeMessageEnd();
+ }
+
+ public TExecuteStatementResp 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_ExecuteStatement();
+ }
+ }
+
+ public void GetTypeInfo(TGetTypeInfoReq req, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException {
+ checkReady();
+ GetTypeInfo_call method_call = new GetTypeInfo_call(req, resultHandler, this, ___protocolFactory, ___transport);
+ this.___currentMethod = method_call;
+ ___manager.call(method_call);
+ }
+
+ public static class GetTypeInfo_call extends org.apache.thrift.async.TAsyncMethodCall {
+ private TGetTypeInfoReq req;
+ public GetTypeInfo_call(TGetTypeInfoReq 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("GetTypeInfo", org.apache.thrift.protocol.TMessageType.CALL, 0));
+ GetTypeInfo_args args = new GetTypeInfo_args();
+ args.setReq(req);
+ args.write(prot);
+ prot.writeMessageEnd();
+ }
+
+ public TGetTypeInfoResp 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_GetTypeInfo();
+ }
+ }
+
+ public void GetCatalogs(TGetCatalogsReq req, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException {
+ checkReady();
+ GetCatalogs_call method_call = new GetCatalogs_call(req, resultHandler, this, ___protocolFactory, ___transport);
+ this.___currentMethod = method_call;
+ ___manager.call(method_call);
+ }
+
+ public static class GetCatalogs_call extends org.apache.thrift.async.TAsyncMethodCall {
+ private TGetCatalogsReq req;
+ public GetCatalogs_call(TGetCatalogsReq 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("GetCatalogs", org.apache.thrift.protocol.TMessageType.CALL, 0));
+ GetCatalogs_args args = new GetCatalogs_args();
+ args.setReq(req);
+ args.write(prot);
+ prot.writeMessageEnd();
+ }
+
+ public TGetCatalogsResp 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_GetCatalogs();
+ }
+ }
+
+ public void GetSchemas(TGetSchemasReq req, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException {
+ checkReady();
+ GetSchemas_call method_call = new GetSchemas_call(req, resultHandler, this, ___protocolFactory, ___transport);
+ this.___currentMethod = method_call;
+ ___manager.call(method_call);
+ }
+
+ public static class GetSchemas_call extends org.apache.thrift.async.TAsyncMethodCall {
+ private TGetSchemasReq req;
+ public GetSchemas_call(TGetSchemasReq 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("GetSchemas", org.apache.thrift.protocol.TMessageType.CALL, 0));
+ GetSchemas_args args = new GetSchemas_args();
+ args.setReq(req);
+ args.write(prot);
+ prot.writeMessageEnd();
+ }
+
+ public TGetSchemasResp 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_GetSchemas();
+ }
+ }
+
+ public void GetTables(TGetTablesReq req, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException {
+ checkReady();
+ GetTables_call method_call = new GetTables_call(req, resultHandler, this, ___protocolFactory, ___transport);
+ this.___currentMethod = method_call;
+ ___manager.call(method_call);
+ }
+
+ public static class GetTables_call extends org.apache.thrift.async.TAsyncMethodCall {
+ private TGetTablesReq req;
+ public GetTables_call(TGetTablesReq 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("GetTables", org.apache.thrift.protocol.TMessageType.CALL, 0));
+ GetTables_args args = new GetTables_args();
+ args.setReq(req);
+ args.write(prot);
+ prot.writeMessageEnd();
+ }
+
+ public TGetTablesResp 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_GetTables();
+ }
+ }
+
+ public void GetTableTypes(TGetTableTypesReq req, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException {
+ checkReady();
+ GetTableTypes_call method_call = new GetTableTypes_call(req, resultHandler, this, ___protocolFactory, ___transport);
+ this.___currentMethod = method_call;
+ ___manager.call(method_call);
+ }
+
+ public static class GetTableTypes_call extends org.apache.thrift.async.TAsyncMethodCall {
+ private TGetTableTypesReq req;
+ public GetTableTypes_call(TGetTableTypesReq 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("GetTableTypes", org.apache.thrift.protocol.TMessageType.CALL, 0));
+ GetTableTypes_args args = new GetTableTypes_args();
+ args.setReq(req);
+ args.write(prot);
+ prot.writeMessageEnd();
+ }
+
+ public TGetTableTypesResp 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_GetTableTypes();
+ }
+ }
+
+ public void GetColumns(TGetColumnsReq req, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException {
+ checkReady();
+ GetColumns_call method_call = new GetColumns_call(req, resultHandler, this, ___protocolFactory, ___transport);
+ this.___currentMethod = method_call;
+ ___manager.call(method_call);
+ }
+
+ public static class GetColumns_call extends org.apache.thrift.async.TAsyncMethodCall {
+ private TGetColumnsReq req;
+ public GetColumns_call(TGetColumnsReq 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("GetColumns", org.apache.thrift.protocol.TMessageType.CALL, 0));
+ GetColumns_args args = new GetColumns_args();
+ args.setReq(req);
+ args.write(prot);
+ prot.writeMessageEnd();
+ }
+
+ public TGetColumnsResp 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_GetColumns();
+ }
+ }
+
+ public void GetFunctions(TGetFunctionsReq req, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException {
+ checkReady();
+ GetFunctions_call method_call = new GetFunctions_call(req, resultHandler, this, ___protocolFactory, ___transport);
+ this.___currentMethod = method_call;
+ ___manager.call(method_call);
+ }
+
+ public static class GetFunctions_call extends org.apache.thrift.async.TAsyncMethodCall {
+ private TGetFunctionsReq req;
+ public GetFunctions_call(TGetFunctionsReq 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("GetFunctions", org.apache.thrift.protocol.TMessageType.CALL, 0));
+ GetFunctions_args args = new GetFunctions_args();
+ args.setReq(req);
+ args.write(prot);
+ prot.writeMessageEnd();
+ }
+
+ public TGetFunctionsResp 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_GetFunctions();
+ }
+ }
+
+ public void GetOperationStatus(TGetOperationStatusReq req, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException {
+ checkReady();
+ GetOperationStatus_call method_call = new GetOperationStatus_call(req, resultHandler, this, ___protocolFactory, ___transport);
+ this.___currentMethod = method_call;
+ ___manager.call(method_call);
+ }
+
+ public static class GetOperationStatus_call extends org.apache.thrift.async.TAsyncMethodCall {
+ private TGetOperationStatusReq req;
+ public GetOperationStatus_call(TGetOperationStatusReq 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("GetOperationStatus", org.apache.thrift.protocol.TMessageType.CALL, 0));
+ GetOperationStatus_args args = new GetOperationStatus_args();
+ args.setReq(req);
+ args.write(prot);
+ prot.writeMessageEnd();
+ }
+
+ public TGetOperationStatusResp 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_GetOperationStatus();
+ }
+ }
+
+ public void CancelOperation(TCancelOperationReq req, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException {
+ checkReady();
+ CancelOperation_call method_call = new CancelOperation_call(req, resultHandler, this, ___protocolFactory, ___transport);
+ this.___currentMethod = method_call;
+ ___manager.call(method_call);
+ }
+
+ public static class CancelOperation_call extends org.apache.thrift.async.TAsyncMethodCall {
+ private TCancelOperationReq req;
+ public CancelOperation_call(TCancelOperationReq 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("CancelOperation", org.apache.thrift.protocol.TMessageType.CALL, 0));
+ CancelOperation_args args = new CancelOperation_args();
+ args.setReq(req);
+ args.write(prot);
+ prot.writeMessageEnd();
+ }
+
+ public TCancelOperationResp 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_CancelOperation();
+ }
+ }
+
+ public void CloseOperation(TCloseOperationReq req, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException {
+ checkReady();
+ CloseOperation_call method_call = new CloseOperation_call(req, resultHandler, this, ___protocolFactory, ___transport);
+ this.___currentMethod = method_call;
+ ___manager.call(method_call);
+ }
+
+ public static class CloseOperation_call extends org.apache.thrift.async.TAsyncMethodCall {
+ private TCloseOperationReq req;
+ public CloseOperation_call(TCloseOperationReq 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("CloseOperation", org.apache.thrift.protocol.TMessageType.CALL, 0));
+ CloseOperation_args args = new CloseOperation_args();
+ args.setReq(req);
+ args.write(prot);
+ prot.writeMessageEnd();
+ }
+
+ public TCloseOperationResp 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_CloseOperation();
+ }
+ }
+
+ public void GetResultSetMetadata(TGetResultSetMetadataReq req, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException {
+ checkReady();
+ GetResultSetMetadata_call method_call = new GetResultSetMetadata_call(req, resultHandler, this, ___protocolFactory, ___transport);
+ this.___currentMethod = method_call;
+ ___manager.call(method_call);
+ }
+
+ public static class GetResultSetMetadata_call extends org.apache.thrift.async.TAsyncMethodCall {
+ private TGetResultSetMetadataReq req;
+ public GetResultSetMetadata_call(TGetResultSetMetadataReq 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("GetResultSetMetadata", org.apache.thrift.protocol.TMessageType.CALL, 0));
+ GetResultSetMetadata_args args = new GetResultSetMetadata_args();
+ args.setReq(req);
+ args.write(prot);
+ prot.writeMessageEnd();
+ }
+
+ public TGetResultSetMetadataResp 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_GetResultSetMetadata();
+ }
+ }
+
+ public void FetchResults(TFetchResultsReq req, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException {
+ checkReady();
+ FetchResults_call method_call = new FetchResults_call(req, resultHandler, this, ___protocolFactory, ___transport);
+ this.___currentMethod = method_call;
+ ___manager.call(method_call);
+ }
+
+ public static class FetchResults_call extends org.apache.thrift.async.TAsyncMethodCall {
+ private TFetchResultsReq req;
+ public FetchResults_call(TFetchResultsReq 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("FetchResults", org.apache.thrift.protocol.TMessageType.CALL, 0));
+ FetchResults_args args = new FetchResults_args();
+ args.setReq(req);
+ args.write(prot);
+ prot.writeMessageEnd();
+ }
+
+ public TFetchResultsResp 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_FetchResults();
+ }
+ }
+
+ public void GetDelegationToken(TGetDelegationTokenReq req, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException {
+ checkReady();
+ GetDelegationToken_call method_call = new GetDelegationToken_call(req, resultHandler, this, ___protocolFactory, ___transport);
+ this.___currentMethod = method_call;
+ ___manager.call(method_call);
+ }
+
+ public static class GetDelegationToken_call extends org.apache.thrift.async.TAsyncMethodCall {
+ private TGetDelegationTokenReq req;
+ public GetDelegationToken_call(TGetDelegationTokenReq 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("GetDelegationToken", org.apache.thrift.protocol.TMessageType.CALL, 0));
+ GetDelegationToken_args args = new GetDelegationToken_args();
+ args.setReq(req);
+ args.write(prot);
+ prot.writeMessageEnd();
+ }
+
+ public TGetDelegationTokenResp 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_GetDelegationToken();
+ }
+ }
+
+ public void CancelDelegationToken(TCancelDelegationTokenReq req, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException {
+ checkReady();
+ CancelDelegationToken_call method_call = new CancelDelegationToken_call(req, resultHandler, this, ___protocolFactory, ___transport);
+ this.___currentMethod = method_call;
+ ___manager.call(method_call);
+ }
+
+ public static class CancelDelegationToken_call extends org.apache.thrift.async.TAsyncMethodCall {
+ private TCancelDelegationTokenReq req;
+ public CancelDelegationToken_call(TCancelDelegationTokenReq 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("CancelDelegationToken", org.apache.thrift.protocol.TMessageType.CALL, 0));
+ CancelDelegationToken_args args = new CancelDelegationToken_args();
+ args.setReq(req);
+ args.write(prot);
+ prot.writeMessageEnd();
+ }
+
+ public TCancelDelegationTokenResp 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_CancelDelegationToken();
+ }
+ }
+
+ public void RenewDelegationToken(TRenewDelegationTokenReq req, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException {
+ checkReady();
+ RenewDelegationToken_call method_call = new RenewDelegationToken_call(req, resultHandler, this, ___protocolFactory, ___transport);
+ this.___currentMethod = method_call;
+ ___manager.call(method_call);
+ }
+
+ public static class RenewDelegationToken_call extends org.apache.thrift.async.TAsyncMethodCall {
+ private TRenewDelegationTokenReq req;
+ public RenewDelegationToken_call(TRenewDelegationTokenReq 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("RenewDelegationToken", org.apache.thrift.protocol.TMessageType.CALL, 0));
+ RenewDelegationToken_args args = new RenewDelegationToken_args();
+ args.setReq(req);
+ args.write(prot);
+ prot.writeMessageEnd();
+ }
+
+ public TRenewDelegationTokenResp 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_RenewDelegationToken();
+ }
+ }
+
+ }
+
+ public static class Processor<I extends Iface> extends org.apache.thrift.TBaseProcessor<I> implements org.apache.thrift.TProcessor {
+ private static final Logger LOGGER = LoggerFactory.getLogger(Processor.class.getName());
+ public Processor(I iface) {
+ super(iface, getProcessMap(new HashMap<String, org.apache.thrift.ProcessFunction<I, ? extends org.apache.thrift.TBase>>()));
+ }
+
+ protected Processor(I iface, Map<String, org.apache.thrift.ProcessFunction<I, ? extends org.apache.thrift.TBase>> processMap) {
+ super(iface, getProcessMap(processMap));
+ }
+
+ private static <I extends Iface> Map<String, org.apache.thrift.ProcessFunction<I, ? extends org.apache.thrift.TBase>> getProcessMap(Map<String, org.apache.thrift.ProcessFunction<I, ? extends org.apache.thrift.TBase>> processMap) {
+ processMap.put("OpenSession", new OpenSession());
+ processMap.put("CloseSession", new CloseSession());
+ processMap.put("GetInfo", new GetInfo());
+ processMap.put("ExecuteStatement", new ExecuteStatement());
+ processMap.put("GetTypeInfo", new GetTypeInfo());
+ processMap.put("GetCatalogs", new GetCatalogs());
+ processMap.put("GetSchemas", new GetSchemas());
+ processMap.put("GetTables", new GetTables());
+ processMap.put("GetTableTypes", new GetTableTypes());
+ processMap.put("GetColumns", new GetColumns());
+ processMap.put("GetFunctions", new GetFunctions());
+ processMap.put("GetOperationStatus", new GetOperationStatus());
+ processMap.put("CancelOperation", new CancelOperation());
+ processMap.put("CloseOperation", new CloseOperation());
+ processMap.put("GetResultSetMetadata", new GetResultSetMetadata());
+ processMap.put("FetchResults", new FetchResults());
+ processMap.put("GetDelegationToken", new GetDelegationToken());
+ processMap.put("CancelDelegationToken", new CancelDelegationToken());
+ processMap.put("RenewDelegationToken", new RenewDelegationToken());
+ return processMap;
+ }
+
+ public static class OpenSession<I extends Iface> extends org.apache.thrift.ProcessFunction<I, OpenSession_args> {
+ public OpenSession() {
+ super("OpenSession");
+ }
+
+ public OpenSession_args getEmptyArgsInstance() {
+ return new OpenSession_args();
+ }
+
+ protected boolean isOneway() {
+ return false;
+ }
+
+ public OpenSession_result getResult(I iface, OpenSession_args args) throws org.apache.thrift.TException {
+ OpenSession_result result = new OpenSession_result();
+ result.success = iface.OpenSession(args.req);
+ return result;
+ }
+ }
+
+ public static class CloseSession<I extends Iface> extends org.apache.thrift.ProcessFunction<I, CloseSession_args> {
+ public CloseSession() {
+ super("CloseSession");
+ }
+
+ public CloseSession_args getEmptyArgsInstance() {
+ return new CloseSession_args();
+ }
+
+ protected boolean isOneway() {
+ return false;
+ }
+
+ public CloseSession_result getResult(I iface, CloseSession_args args) throws org.apache.thrift.TException {
+ CloseSession_result result = new CloseSession_result();
+ result.success = iface.CloseSession(args.req);
+ return result;
+ }
+ }
+
+ public static class GetInfo<I extends Iface> extends org.apache.thrift.ProcessFunction<I, GetInfo_args> {
+ public GetInfo() {
+ super("GetInfo");
+ }
+
+ public GetInfo_args getEmptyArgsInstance() {
+ return new GetInfo_args();
+ }
+
+ protected boolean isOneway() {
+ return false;
+ }
+
+ public GetInfo_result getResult(I iface, GetInfo_args args) throws org.apache.thrift.TException {
+ GetInfo_result result = new GetInfo_result();
+ result.success = iface.GetInfo(args.req);
+ return result;
+ }
+ }
+
+ public static class ExecuteStatement<I extends Iface> extends org.apache.thrift.ProcessFunction<I, ExecuteStatement_args> {
+ public ExecuteStatement() {
+ super("ExecuteStatement");
+ }
+
+ public ExecuteStatement_args getEmptyArgsInstance() {
+ return new ExecuteStatement_args();
+ }
+
+ protected boolean isOneway() {
+ return false;
+ }
+
+ public ExecuteStatement_result getResult(I iface, ExecuteStatement_args args) throws org.apache.thrift.TException {
+ ExecuteStatement_result result = new ExecuteStatement_result();
+ result.success = iface.ExecuteStatement(args.req);
+ return result;
+ }
+ }
+
+ public static class GetTypeInfo<I extends Iface> extends org.apache.thrift.ProcessFunction<I, GetTypeInfo_args> {
+ public GetTypeInfo() {
+ super("GetTypeInfo");
+ }
+
+ public GetTypeInfo_args getEmptyArgsInstance() {
+ return new GetTypeInfo_args();
+ }
+
+ protected boolean isOneway() {
+ return false;
+ }
+
+ public GetTypeInfo_result getResult(I iface, GetTypeInfo_args args) throws org.apache.thrift.TException {
+ GetTypeInfo_result result = new GetTypeInfo_result();
+ result.success = iface.GetTypeInfo(args.req);
+ return result;
+ }
+ }
+
+ public static class GetCatalogs<I extends Iface> extends org.apache.thrift.ProcessFunction<I, GetCatalogs_args> {
+ public GetCatalogs() {
+ super("GetCatalogs");
+ }
+
+ public GetCatalogs_args getEmptyArgsInstance() {
+ return new GetCatalogs_args();
+ }
+
+ protected boolean isOneway() {
+ return false;
+ }
+
+ public GetCatalogs_result getResult(I iface, GetCatalogs_args args) throws org.apache.thrift.TException {
+ GetCatalogs_result result = new GetCatalogs_result();
+ result.success = iface.GetCatalogs(args.req);
+ return result;
+ }
+ }
+
+ public static class GetSchemas<I extends Iface> extends org.apache.thrift.ProcessFunction<I, GetSchemas_args> {
+ public GetSchemas() {
+ super("GetSchemas");
+ }
+
+ public GetSchemas_args getEmptyArgsInstance() {
+ return new GetSchemas_args();
+ }
+
+ protected boolean isOneway() {
+ return false;
+ }
+
+ public GetSchemas_result getResult(I iface, GetSchemas_args args) throws org.apache.thrift.TException {
+ GetSchemas_result result = new GetSchemas_result();
+ result.success = iface.GetSchemas(args.req);
+ return result;
+ }
+ }
+
+ public static class GetTables<I extends Iface> extends org.apache.thrift.ProcessFunction<I, GetTables_args> {
+ public GetTables() {
+ super("GetTables");
+ }
+
+ public GetTables_args getEmptyArgsInstance() {
+ return new GetTables_args();
+ }
+
+ protected boolean isOneway() {
+ return false;
+ }
+
+ public GetTables_result getResult(I iface, GetTables_args args) throws org.apache.thrift.TException {
+ GetTables_result result = new GetTables_result();
+ result.success = iface.GetTables(args.req);
+ return result;
+ }
+ }
+
+ public static class GetTableTypes<I extends Iface> extends org.apache.thrift.ProcessFunction<I, GetTableTypes_args> {
+ public GetTableTypes() {
+ super("GetTableTypes");
+ }
+
+ public GetTableTypes_args getEmptyArgsInstance() {
+ return new GetTableTypes_args();
+ }
+
+ protected boolean isOneway() {
+ return false;
+ }
+
+ public GetTableTypes_result getResult(I iface, GetTableTypes_args args) throws org.apache.thrift.TException {
+ GetTableTypes_result result = new GetTableTypes_result();
+ result.success = iface.GetTableTypes(args.req);
+ return result;
+ }
+ }
+
+ public static class GetColumns<I extends Iface> extends org.apache.thrift.ProcessFunction<I, GetColumns_args> {
+ public GetColumns() {
+ super("GetColumns");
+ }
+
+ public GetColumns_args getEmptyArgsInstance() {
+ return new GetColumns_args();
+ }
+
+ protected boolean isOneway() {
+ return false;
+ }
+
+ public GetColumns_result getResult(I iface, GetColumns_args args) throws org.apache.thrift.TException {
+ GetColumns_result result = new GetColumns_result();
+ result.success = iface.GetColumns(args.req);
+ return result;
+ }
+ }
+
+ public static class GetFunctions<I extends Iface> extends org.apache.thrift.ProcessFunction<I, GetFunctions_args> {
+ public GetFunctions() {
+ super("GetFunctions");
+ }
+
+ public GetFunctions_args getEmptyArgsInstance() {
+ return new GetFunctions_args();
+ }
+
+ protected boolean isOneway() {
+ return false;
+ }
+
+ public GetFunctions_result getResult(I iface, GetFunctions_args args) throws org.apache.thrift.TException {
+ GetFunctions_result result = new GetFunctions_result();
+ result.success = iface.GetFunctions(args.req);
+ return result;
+ }
+ }
+
+ public static class GetOperationStatus<I extends Iface> extends org.apache.thrift.ProcessFunction<I, GetOperationStatus_args> {
+ public GetOperationStatus() {
+ super("GetOperationStatus");
+ }
+
+ public GetOperationStatus_args getEmptyArgsInstance() {
+ return new GetOperationStatus_args();
+ }
+
+ protected boolean isOneway() {
+ return false;
+ }
+
+ public GetOperationStatus_result getResult(I iface, GetOperationStatus_args args) throws org.apache.thrift.TException {
+ GetOperationStatus_result result = new GetOperationStatus_result();
+ result.success = iface.GetOperationStatus(args.req);
+ return result;
+ }
+ }
+
+ public static class CancelOperation<I extends Iface> extends org.apache.thrift.ProcessFunction<I, CancelOperation_args> {
+ public CancelOperation() {
+ super("CancelOperation");
+ }
+
+ public CancelOperation_args getEmptyArgsInstance() {
+ return new CancelOperation_args();
+ }
+
+ protected boolean isOneway() {
+ return false;
+ }
+
+ public CancelOperation_result getResult(I iface, CancelOperation_args args) throws org.apache.thrift.TException {
+ CancelOperation_result result = new CancelOperation_result();
+ result.success = iface.CancelOperation(args.req);
+ return result;
+ }
+ }
+
+ public static class CloseOperation<I extends Iface> extends org.apache.thrift.ProcessFunction<I, CloseOperation_args> {
+ public CloseOperation() {
+ super("CloseOperation");
+ }
+
+ public CloseOperation_args getEmptyArgsInstance() {
+ return new CloseOperation_args();
+ }
+
+ protected boolean isOneway() {
+ return false;
+ }
+
+ public CloseOperation_result getResult(I iface, CloseOperation_args args) throws org.apache.thrift.TException {
+ CloseOperation_result result = new CloseOperation_result();
+ result.success = iface.CloseOperation(args.req);
+ return result;
+ }
+ }
+
+ public static class GetResultSetMetadata<I extends Iface> extends org.apache.thrift.ProcessFunction<I, GetResultSetMetadata_args> {
+ public GetResultSetMetadata() {
+ super("GetResultSetMetadata");
+ }
+
+ public GetResultSetMetadata_args getEmptyArgsInstance() {
+ return new GetResultSetMetadata_args();
+ }
+
+ protected boolean isOneway() {
+ return false;
+ }
+
+ public GetResultSetMetadata_result getResult(I iface, GetResultSetMetadata_args args) throws org.apache.thrift.TException {
+ GetResultSetMetadata_result result = new GetResultSetMetadata_result();
+ result.success = iface.GetResultSetMetadata(args.req);
+ return result;
+ }
+ }
+
+ public static class FetchResults<I extends Iface> extends org.apache.thrift.ProcessFunction<I, FetchResults_args> {
+ public FetchResults() {
+ super("FetchResults");
+ }
+
+ public FetchResults_args getEmptyArgsInstance() {
+ return new FetchResults_args();
+ }
+
+ protected boolean isOneway() {
+ return false;
+ }
+
+ public FetchResults_result getResult(I iface, FetchResults_args args) throws org.apache.thrift.TException {
+ FetchResults_result result = new FetchResults_result();
+ result.success = iface.FetchResults(args.req);
+ return result;
+ }
+ }
+
+ public static class GetDelegationToken<I extends Iface> extends org.apache.thrift.ProcessFunction<I, GetDelegationToken_args> {
+ public GetDelegationToken() {
+ super("GetDelegationToken");
+ }
+
+ public GetDelegationToken_args getEmptyArgsInstance() {
+ return new GetDelegationToken_args();
+ }
+
+ protected boolean isOneway() {
+ return false;
+ }
+
+ public GetDelegationToken_result getResult(I iface, GetDelegationToken_args args) throws org.apache.thrift.TException {
+ GetDelegationToken_result result = new GetDelegationToken_result();
+ result.success = iface.GetDelegationToken(args.req);
+ return result;
+ }
+ }
+
+ public static class CancelDelegationToken<I extends Iface> extends org.apache.thrift.ProcessFunction<I, CancelDelegationToken_args> {
+ public CancelDelegationToken() {
+ super("CancelDelegationToken");
+ }
+
+ public CancelDelegationToken_args getEmptyArgsInstance() {
+ return new CancelDelegationToken_args();
+ }
+
+ protected boolean isOneway() {
+ return false;
+ }
+
+ public CancelDelegationToken_result getResult(I iface, CancelDelegationToken_args args) throws org.apache.thrift.TException {
+ CancelDelegationToken_result result = new CancelDelegationToken_result();
+ result.success = iface.CancelDelegationToken(args.req);
+ return result;
+ }
+ }
+
+ public static class RenewDelegationToken<I extends Iface> extends org.apache.thrift.ProcessFunction<I, RenewDelegationToken_args> {
+ public RenewDelegationToken() {
+ super("RenewDelegationToken");
+ }
+
+ public RenewDelegationToken_args getEmptyArgsInstance() {
+ return new RenewDelegationToken_args();
+ }
+
+ protected boolean isOneway() {
+ return false;
+ }
+
+ public RenewDelegationToken_result getResult(I iface, RenewDelegationToken_args args) throws org.apache.thrift.TException {
+ RenewDelegationToken_result result = new RenewDelegationToken_result();
+ result.success = iface.RenewDelegationToken(args.req);
+ return result;
+ }
+ }
+
+ }
+
+ public static class AsyncProcessor<I extends AsyncIface> extends org.apache.thrift.TBaseAsyncProcessor<I> {
+ private static final Logger LOGGER = LoggerFactory.getLogger(AsyncProcessor.class.getName());
+ public AsyncProcessor(I iface) {
+ super(iface, getProcessMap(new HashMap<String, org.apache.thrift.AsyncProcessFunction<I, ? extends org.apache.thrift.TBase, ?>>()));
+ }
+
+ protected AsyncProcessor(I iface, Map<String, org.apache.thrift.AsyncProcessFunction<I, ? extends org.apache.thrift.TBase, ?>> processMap) {
+ super(iface, getProcessMap(processMap));
+ }
+
+ private static <I extends AsyncIface> Map<String, org.apache.thrift.AsyncProcessFunction<I, ? extends org.apache.thrift.TBase,?>> getProcessMap(Map<String, org.apache.thrift.AsyncProcessFunction<I, ? extends org.apache.thrift.TBase, ?>> processMap) {
+ processMap.put("OpenSession", new OpenSession());
+ processMap.put("CloseSession", new CloseSession());
+ processMap.put("GetInfo", new GetInfo());
+ processMap.put("ExecuteStatement", new ExecuteStatement());
+ processMap.put("GetTypeInfo", new GetTypeInfo());
+ processMap.put("GetCatalogs", new GetCatalogs());
+ processMap.put("GetSchemas", new GetSchemas());
+ processMap.put("GetTables", new GetTables());
+ processMap.put("GetTableTypes", new GetTableTypes());
+ processMap.put("GetColumns", new GetColumns());
+ processMap.put("GetFunctions", new GetFunctions());
+ processMap.put("GetOperationStatus", new GetOperationStatus());
+ processMap.put("CancelOperation", new CancelOperation());
+ processMap.put("CloseOperation", new CloseOperation());
+ processMap.put("GetResultSetMetadata", new GetResultSetMetadata());
+ processMap.put("FetchResults", new FetchResults());
+ processMap.put("GetDelegationToken", new GetDelegationToken());
+ processMap.put("CancelDelegationToken", new CancelDelegationToken());
+ processMap.put("RenewDelegationToken", new RenewDelegationToken());
+ return processMap;
+ }
+
+ public static class OpenSession<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, OpenSession_args, TOpenSessionResp> {
+ public OpenSession() {
+ super("OpenSession");
+ }
+
+ public OpenSession_args getEmptyArgsInstance() {
+ return new OpenSession_args();
+ }
+
+ public AsyncMethodCallback<TOpenSessionResp> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
+ final org.apache.thrift.AsyncProcessFunction fcall = this;
+ return new AsyncMethodCallback<TOpenSessionResp>() {
+ public void onComplete(TOpenSessionResp o) {
+ OpenSession_result result = new OpenSession_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;
+ OpenSession_result result = new OpenSession_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();
+ }
+ };
+ }
+
+ protected boolean isOneway() {
+ return false;
+ }
+
+ public void start(I iface, OpenSession_args args, org.apache.thrift.async.AsyncMethodCallback<TOpenSessionResp> resultHandler) throws TException {
+ iface.OpenSession(args.req,resultHandler);
+ }
+ }
+
+ public static class CloseSession<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, CloseSession_args, TCloseSessionResp> {
+ public CloseSession() {
+ super("CloseSession");
+ }
+
+ public CloseSession_args getEmptyArgsInstance() {
+ return new CloseSession_args();
+ }
+
+ public AsyncMethodCallback<TCloseSessionResp> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
+ final org.apache.thrift.AsyncProcessFunction fcall = this;
+ return new AsyncMethodCallback<TCloseSessionResp>() {
+ public void onComplete(TCloseSessionResp o) {
+ CloseSession_result result = new CloseSession_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;
+ CloseSession_result result = new CloseSession_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();
+ }
+ };
+ }
+
+ protected boolean isOneway() {
+ return false;
+ }
+
+ public void start(I iface, CloseSession_args args, org.apache.thrift.async.AsyncMethodCallback<TCloseSessionResp> resultHandler) throws TException {
+ iface.CloseSession(args.req,resultHandler);
+ }
+ }
+
+ public static class GetInfo<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, GetInfo_args, TGetInfoResp> {
+ public GetInfo() {
+ super("GetInfo");
+ }
+
+ public GetInfo_args getEmptyArgsInstance() {
+ return new GetInfo_args();
+ }
+
+ public AsyncMethodCallback<TGetInfoResp> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
+ final org.apache.thrift.AsyncProcessFunction fcall = this;
+ return new AsyncMethodCallback<TGetInfoResp>() {
+ public void onComplete(TGetInfoResp o) {
+ GetInfo_result result = new GetInfo_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;
+ GetInfo_result result = new GetInfo_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();
+ }
+ };
+ }
+
+ protected boolean isOneway() {
+ return false;
+ }
+
+ public void start(I iface, GetInfo_args args, org.apache.thrift.async.AsyncMethodCallback<TGetInfoResp> resultHandler) throws TException {
+ iface.GetInfo(args.req,resultHandler);
+ }
+ }
+
+ public static class ExecuteStatement<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, ExecuteStatement_args, TExecuteStatementResp> {
+ public ExecuteStatement() {
+ super("ExecuteStatement");
+ }
+
+ public ExecuteStatement_args getEmptyArgsInstance() {
+ return new ExecuteStatement_args();
+ }
+
+ public AsyncMethodCallback<TExecuteStatementResp> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
+ final org.apache.thrift.AsyncProcessFunction fcall = this;
+ return new AsyncMethodCallback<TExecuteStatementResp>() {
+ public void onComplete(TExecuteStatementResp o) {
+ ExecuteStatement_result result = new ExecuteStatement_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;
+ ExecuteStatement_result result = new ExecuteStatement_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();
+ }
+ };
+ }
+
+ protected boolean isOneway() {
+ return false;
+ }
+
+ public void start(I iface, ExecuteStatement_args args, org.apache.thrift.async.AsyncMethodCallback<TExecuteStatementResp> resultHandler) throws TException {
+ iface.ExecuteStatement(args.req,resultHandler);
+ }
+ }
+
+ public static class GetTypeInfo<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, GetTypeInfo_args, TGetTypeInfoResp> {
+ public GetTypeInfo() {
+ super("GetTypeInfo");
+ }
+
+ public GetTypeInfo_args getEmptyArgsInstance() {
+ return new GetTypeInfo_args();
+ }
+
+ public AsyncMethodCallback<TGetTypeInfoResp> getResultHandler(final AsyncFrameBuffer fb, final int seqid) {
+ final org.apache.thrift.AsyncProcessFunction fcall = this;
+ return new AsyncMethodCallback<TGetTypeInfoResp>() {
+ public void onComplete(TGetTypeInfoResp o) {
+ GetTypeInfo_result result = new GetTypeInfo_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.thr
<TRUNCATED>