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:16 UTC
[06/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/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TCLIService.java
----------------------------------------------------------------------
diff --git a/service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TCLIService.java b/service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TCLIService.java
deleted file mode 100644
index ded848f..0000000
--- a/service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TCLIService.java
+++ /dev/null
@@ -1,16422 +0,0 @@
-/**
- * Autogenerated by Thrift Compiler (0.9.3)
- *
- * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
- * @generated
- */
-package org.apache.hive.service.cli.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.3)")
-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.thrift.protocol.TMessageType.REPLY;
<TRUNCATED>