Versions in this module Expand all Collapse all v1 v1.0.0 Feb 15, 2019 Changes in this version + var BeeswaxException_ErrorCode_DEFAULT int32 = 0 + var BeeswaxException_SQLState_DEFAULT string = " " + var BeeswaxServiceDumpConfigResult_Success_DEFAULT string + var BeeswaxServiceEchoResult_Success_DEFAULT string + var BeeswaxServiceGetDefaultConfigurationResult_Success_DEFAULT []*ConfigVariable + var BeeswaxServiceGetLogResult_Success_DEFAULT string + var GoUnusedProtection__ int + var ResultsMetadata_Schema_DEFAULT *hive_metastore.Schema + type BeeswaxException struct + ErrorCode int32 + Handle *QueryHandle + LogContext LogContextId + Message string + SQLState string + var BeeswaxServiceCloseResult_Error2_DEFAULT *BeeswaxException + var BeeswaxServiceExecuteAndWaitResult_Error_DEFAULT *BeeswaxException + var BeeswaxServiceExplainResult_Error_DEFAULT *BeeswaxException + var BeeswaxServiceFetchResult_Error2_DEFAULT *BeeswaxException + var BeeswaxServiceQueryResult_Error_DEFAULT *BeeswaxException + func NewBeeswaxException() *BeeswaxException + func (p *BeeswaxException) Error() string + func (p *BeeswaxException) GetErrorCode() int32 + func (p *BeeswaxException) GetHandle() *QueryHandle + func (p *BeeswaxException) GetLogContext() LogContextId + func (p *BeeswaxException) GetMessage() string + func (p *BeeswaxException) GetSQLState() string + func (p *BeeswaxException) IsSetErrorCode() bool + func (p *BeeswaxException) IsSetHandle() bool + func (p *BeeswaxException) IsSetSQLState() bool + func (p *BeeswaxException) Read(iprot thrift.TProtocol) error + func (p *BeeswaxException) ReadField1(iprot thrift.TProtocol) error + func (p *BeeswaxException) ReadField2(iprot thrift.TProtocol) error + func (p *BeeswaxException) ReadField3(iprot thrift.TProtocol) error + func (p *BeeswaxException) ReadField4(iprot thrift.TProtocol) error + func (p *BeeswaxException) ReadField5(iprot thrift.TProtocol) error + func (p *BeeswaxException) String() string + func (p *BeeswaxException) Write(oprot thrift.TProtocol) error + type BeeswaxService interface + Clean func(ctx context.Context, log_context LogContextId) (err error) + Close func(ctx context.Context, handle *QueryHandle) (err error) + DumpConfig func(ctx context.Context) (r string, err error) + Echo func(ctx context.Context, s string) (r string, err error) + ExecuteAndWait func(ctx context.Context, query *Query, clientCtx LogContextId) (r *QueryHandle, err error) + Explain func(ctx context.Context, query *Query) (r *QueryExplanation, err error) + Fetch func(ctx context.Context, query_id *QueryHandle, start_over bool, fetch_size int32) (r *Results, err error) + GetDefaultConfiguration func(ctx context.Context, include_hadoop bool) (r []*ConfigVariable, err error) + GetLog func(ctx context.Context, context LogContextId) (r string, err error) + GetResultsMetadata func(ctx context.Context, handle *QueryHandle) (r *ResultsMetadata, err error) + GetState func(ctx context.Context, handle *QueryHandle) (r QueryState, err error) + Query func(ctx context.Context, query *Query) (r *QueryHandle, err error) + type BeeswaxServiceCleanArgs struct + LogContext LogContextId + func NewBeeswaxServiceCleanArgs() *BeeswaxServiceCleanArgs + func (p *BeeswaxServiceCleanArgs) GetLogContext() LogContextId + func (p *BeeswaxServiceCleanArgs) Read(iprot thrift.TProtocol) error + func (p *BeeswaxServiceCleanArgs) ReadField1(iprot thrift.TProtocol) error + func (p *BeeswaxServiceCleanArgs) String() string + func (p *BeeswaxServiceCleanArgs) Write(oprot thrift.TProtocol) error + type BeeswaxServiceCleanResult struct + func NewBeeswaxServiceCleanResult() *BeeswaxServiceCleanResult + func (p *BeeswaxServiceCleanResult) Read(iprot thrift.TProtocol) error + func (p *BeeswaxServiceCleanResult) String() string + func (p *BeeswaxServiceCleanResult) Write(oprot thrift.TProtocol) error + type BeeswaxServiceClient struct + func NewBeeswaxServiceClient(c thrift.TClient) *BeeswaxServiceClient + func NewBeeswaxServiceClientFactory(t thrift.TTransport, f thrift.TProtocolFactory) *BeeswaxServiceClient + func NewBeeswaxServiceClientProtocol(t thrift.TTransport, iprot thrift.TProtocol, oprot thrift.TProtocol) *BeeswaxServiceClient + func (p *BeeswaxServiceClient) Clean(ctx context.Context, log_context LogContextId) (err error) + func (p *BeeswaxServiceClient) Client_() thrift.TClient + func (p *BeeswaxServiceClient) Close(ctx context.Context, handle *QueryHandle) (err error) + func (p *BeeswaxServiceClient) DumpConfig(ctx context.Context) (r string, err error) + func (p *BeeswaxServiceClient) Echo(ctx context.Context, s string) (r string, err error) + func (p *BeeswaxServiceClient) ExecuteAndWait(ctx context.Context, query *Query, clientCtx LogContextId) (r *QueryHandle, err error) + func (p *BeeswaxServiceClient) Explain(ctx context.Context, query *Query) (r *QueryExplanation, err error) + func (p *BeeswaxServiceClient) Fetch(ctx context.Context, query_id *QueryHandle, start_over bool, fetch_size int32) (r *Results, err error) + func (p *BeeswaxServiceClient) GetDefaultConfiguration(ctx context.Context, include_hadoop bool) (r []*ConfigVariable, err error) + func (p *BeeswaxServiceClient) GetLog(ctx context.Context, context LogContextId) (r string, err error) + func (p *BeeswaxServiceClient) GetResultsMetadata(ctx context.Context, handle *QueryHandle) (r *ResultsMetadata, err error) + func (p *BeeswaxServiceClient) GetState(ctx context.Context, handle *QueryHandle) (r QueryState, err error) + func (p *BeeswaxServiceClient) Query(ctx context.Context, query *Query) (r *QueryHandle, err error) + type BeeswaxServiceCloseArgs struct + Handle *QueryHandle + func NewBeeswaxServiceCloseArgs() *BeeswaxServiceCloseArgs + func (p *BeeswaxServiceCloseArgs) GetHandle() *QueryHandle + func (p *BeeswaxServiceCloseArgs) IsSetHandle() bool + func (p *BeeswaxServiceCloseArgs) Read(iprot thrift.TProtocol) error + func (p *BeeswaxServiceCloseArgs) ReadField1(iprot thrift.TProtocol) error + func (p *BeeswaxServiceCloseArgs) String() string + func (p *BeeswaxServiceCloseArgs) Write(oprot thrift.TProtocol) error + type BeeswaxServiceCloseResult struct + Error *QueryNotFoundException + Error2 *BeeswaxException + func NewBeeswaxServiceCloseResult() *BeeswaxServiceCloseResult + func (p *BeeswaxServiceCloseResult) GetError() *QueryNotFoundException + func (p *BeeswaxServiceCloseResult) GetError2() *BeeswaxException + func (p *BeeswaxServiceCloseResult) IsSetError() bool + func (p *BeeswaxServiceCloseResult) IsSetError2() bool + func (p *BeeswaxServiceCloseResult) Read(iprot thrift.TProtocol) error + func (p *BeeswaxServiceCloseResult) ReadField1(iprot thrift.TProtocol) error + func (p *BeeswaxServiceCloseResult) ReadField2(iprot thrift.TProtocol) error + func (p *BeeswaxServiceCloseResult) String() string + func (p *BeeswaxServiceCloseResult) Write(oprot thrift.TProtocol) error + type BeeswaxServiceDumpConfigArgs struct + func NewBeeswaxServiceDumpConfigArgs() *BeeswaxServiceDumpConfigArgs + func (p *BeeswaxServiceDumpConfigArgs) Read(iprot thrift.TProtocol) error + func (p *BeeswaxServiceDumpConfigArgs) String() string + func (p *BeeswaxServiceDumpConfigArgs) Write(oprot thrift.TProtocol) error + type BeeswaxServiceDumpConfigResult struct + Success *string + func NewBeeswaxServiceDumpConfigResult() *BeeswaxServiceDumpConfigResult + func (p *BeeswaxServiceDumpConfigResult) GetSuccess() string + func (p *BeeswaxServiceDumpConfigResult) IsSetSuccess() bool + func (p *BeeswaxServiceDumpConfigResult) Read(iprot thrift.TProtocol) error + func (p *BeeswaxServiceDumpConfigResult) ReadField0(iprot thrift.TProtocol) error + func (p *BeeswaxServiceDumpConfigResult) String() string + func (p *BeeswaxServiceDumpConfigResult) Write(oprot thrift.TProtocol) error + type BeeswaxServiceEchoArgs struct + S string + func NewBeeswaxServiceEchoArgs() *BeeswaxServiceEchoArgs + func (p *BeeswaxServiceEchoArgs) GetS() string + func (p *BeeswaxServiceEchoArgs) Read(iprot thrift.TProtocol) error + func (p *BeeswaxServiceEchoArgs) ReadField1(iprot thrift.TProtocol) error + func (p *BeeswaxServiceEchoArgs) String() string + func (p *BeeswaxServiceEchoArgs) Write(oprot thrift.TProtocol) error + type BeeswaxServiceEchoResult struct + Success *string + func NewBeeswaxServiceEchoResult() *BeeswaxServiceEchoResult + func (p *BeeswaxServiceEchoResult) GetSuccess() string + func (p *BeeswaxServiceEchoResult) IsSetSuccess() bool + func (p *BeeswaxServiceEchoResult) Read(iprot thrift.TProtocol) error + func (p *BeeswaxServiceEchoResult) ReadField0(iprot thrift.TProtocol) error + func (p *BeeswaxServiceEchoResult) String() string + func (p *BeeswaxServiceEchoResult) Write(oprot thrift.TProtocol) error + type BeeswaxServiceExecuteAndWaitArgs struct + ClientCtx LogContextId + Query *Query + func NewBeeswaxServiceExecuteAndWaitArgs() *BeeswaxServiceExecuteAndWaitArgs + func (p *BeeswaxServiceExecuteAndWaitArgs) GetClientCtx() LogContextId + func (p *BeeswaxServiceExecuteAndWaitArgs) GetQuery() *Query + func (p *BeeswaxServiceExecuteAndWaitArgs) IsSetQuery() bool + func (p *BeeswaxServiceExecuteAndWaitArgs) Read(iprot thrift.TProtocol) error + func (p *BeeswaxServiceExecuteAndWaitArgs) ReadField1(iprot thrift.TProtocol) error + func (p *BeeswaxServiceExecuteAndWaitArgs) ReadField2(iprot thrift.TProtocol) error + func (p *BeeswaxServiceExecuteAndWaitArgs) String() string + func (p *BeeswaxServiceExecuteAndWaitArgs) Write(oprot thrift.TProtocol) error + type BeeswaxServiceExecuteAndWaitResult struct + Error *BeeswaxException + Success *QueryHandle + func NewBeeswaxServiceExecuteAndWaitResult() *BeeswaxServiceExecuteAndWaitResult + func (p *BeeswaxServiceExecuteAndWaitResult) GetError() *BeeswaxException + func (p *BeeswaxServiceExecuteAndWaitResult) GetSuccess() *QueryHandle + func (p *BeeswaxServiceExecuteAndWaitResult) IsSetError() bool + func (p *BeeswaxServiceExecuteAndWaitResult) IsSetSuccess() bool + func (p *BeeswaxServiceExecuteAndWaitResult) Read(iprot thrift.TProtocol) error + func (p *BeeswaxServiceExecuteAndWaitResult) ReadField0(iprot thrift.TProtocol) error + func (p *BeeswaxServiceExecuteAndWaitResult) ReadField1(iprot thrift.TProtocol) error + func (p *BeeswaxServiceExecuteAndWaitResult) String() string + func (p *BeeswaxServiceExecuteAndWaitResult) Write(oprot thrift.TProtocol) error + type BeeswaxServiceExplainArgs struct + Query *Query + func NewBeeswaxServiceExplainArgs() *BeeswaxServiceExplainArgs + func (p *BeeswaxServiceExplainArgs) GetQuery() *Query + func (p *BeeswaxServiceExplainArgs) IsSetQuery() bool + func (p *BeeswaxServiceExplainArgs) Read(iprot thrift.TProtocol) error + func (p *BeeswaxServiceExplainArgs) ReadField1(iprot thrift.TProtocol) error + func (p *BeeswaxServiceExplainArgs) String() string + func (p *BeeswaxServiceExplainArgs) Write(oprot thrift.TProtocol) error + type BeeswaxServiceExplainResult struct + Error *BeeswaxException + Success *QueryExplanation + func NewBeeswaxServiceExplainResult() *BeeswaxServiceExplainResult + func (p *BeeswaxServiceExplainResult) GetError() *BeeswaxException + func (p *BeeswaxServiceExplainResult) GetSuccess() *QueryExplanation + func (p *BeeswaxServiceExplainResult) IsSetError() bool + func (p *BeeswaxServiceExplainResult) IsSetSuccess() bool + func (p *BeeswaxServiceExplainResult) Read(iprot thrift.TProtocol) error + func (p *BeeswaxServiceExplainResult) ReadField0(iprot thrift.TProtocol) error + func (p *BeeswaxServiceExplainResult) ReadField1(iprot thrift.TProtocol) error + func (p *BeeswaxServiceExplainResult) String() string + func (p *BeeswaxServiceExplainResult) Write(oprot thrift.TProtocol) error + type BeeswaxServiceFetchArgs struct + FetchSize int32 + QueryID *QueryHandle + StartOver bool + func NewBeeswaxServiceFetchArgs() *BeeswaxServiceFetchArgs + func (p *BeeswaxServiceFetchArgs) GetFetchSize() int32 + func (p *BeeswaxServiceFetchArgs) GetQueryID() *QueryHandle + func (p *BeeswaxServiceFetchArgs) GetStartOver() bool + func (p *BeeswaxServiceFetchArgs) IsSetQueryID() bool + func (p *BeeswaxServiceFetchArgs) Read(iprot thrift.TProtocol) error + func (p *BeeswaxServiceFetchArgs) ReadField1(iprot thrift.TProtocol) error + func (p *BeeswaxServiceFetchArgs) ReadField2(iprot thrift.TProtocol) error + func (p *BeeswaxServiceFetchArgs) ReadField3(iprot thrift.TProtocol) error + func (p *BeeswaxServiceFetchArgs) String() string + func (p *BeeswaxServiceFetchArgs) Write(oprot thrift.TProtocol) error + type BeeswaxServiceFetchResult struct + Error *QueryNotFoundException + Error2 *BeeswaxException + Success *Results + func NewBeeswaxServiceFetchResult() *BeeswaxServiceFetchResult + func (p *BeeswaxServiceFetchResult) GetError() *QueryNotFoundException + func (p *BeeswaxServiceFetchResult) GetError2() *BeeswaxException + func (p *BeeswaxServiceFetchResult) GetSuccess() *Results + func (p *BeeswaxServiceFetchResult) IsSetError() bool + func (p *BeeswaxServiceFetchResult) IsSetError2() bool + func (p *BeeswaxServiceFetchResult) IsSetSuccess() bool + func (p *BeeswaxServiceFetchResult) Read(iprot thrift.TProtocol) error + func (p *BeeswaxServiceFetchResult) ReadField0(iprot thrift.TProtocol) error + func (p *BeeswaxServiceFetchResult) ReadField1(iprot thrift.TProtocol) error + func (p *BeeswaxServiceFetchResult) ReadField2(iprot thrift.TProtocol) error + func (p *BeeswaxServiceFetchResult) String() string + func (p *BeeswaxServiceFetchResult) Write(oprot thrift.TProtocol) error + type BeeswaxServiceGetDefaultConfigurationArgs struct + IncludeHadoop bool + func NewBeeswaxServiceGetDefaultConfigurationArgs() *BeeswaxServiceGetDefaultConfigurationArgs + func (p *BeeswaxServiceGetDefaultConfigurationArgs) GetIncludeHadoop() bool + func (p *BeeswaxServiceGetDefaultConfigurationArgs) Read(iprot thrift.TProtocol) error + func (p *BeeswaxServiceGetDefaultConfigurationArgs) ReadField1(iprot thrift.TProtocol) error + func (p *BeeswaxServiceGetDefaultConfigurationArgs) String() string + func (p *BeeswaxServiceGetDefaultConfigurationArgs) Write(oprot thrift.TProtocol) error + type BeeswaxServiceGetDefaultConfigurationResult struct + Success []*ConfigVariable + func NewBeeswaxServiceGetDefaultConfigurationResult() *BeeswaxServiceGetDefaultConfigurationResult + func (p *BeeswaxServiceGetDefaultConfigurationResult) GetSuccess() []*ConfigVariable + func (p *BeeswaxServiceGetDefaultConfigurationResult) IsSetSuccess() bool + func (p *BeeswaxServiceGetDefaultConfigurationResult) Read(iprot thrift.TProtocol) error + func (p *BeeswaxServiceGetDefaultConfigurationResult) ReadField0(iprot thrift.TProtocol) error + func (p *BeeswaxServiceGetDefaultConfigurationResult) String() string + func (p *BeeswaxServiceGetDefaultConfigurationResult) Write(oprot thrift.TProtocol) error + type BeeswaxServiceGetLogArgs struct + Context LogContextId + func NewBeeswaxServiceGetLogArgs() *BeeswaxServiceGetLogArgs + func (p *BeeswaxServiceGetLogArgs) GetContext() LogContextId + func (p *BeeswaxServiceGetLogArgs) Read(iprot thrift.TProtocol) error + func (p *BeeswaxServiceGetLogArgs) ReadField1(iprot thrift.TProtocol) error + func (p *BeeswaxServiceGetLogArgs) String() string + func (p *BeeswaxServiceGetLogArgs) Write(oprot thrift.TProtocol) error + type BeeswaxServiceGetLogResult struct + Error *QueryNotFoundException + Success *string + func NewBeeswaxServiceGetLogResult() *BeeswaxServiceGetLogResult + func (p *BeeswaxServiceGetLogResult) GetError() *QueryNotFoundException + func (p *BeeswaxServiceGetLogResult) GetSuccess() string + func (p *BeeswaxServiceGetLogResult) IsSetError() bool + func (p *BeeswaxServiceGetLogResult) IsSetSuccess() bool + func (p *BeeswaxServiceGetLogResult) Read(iprot thrift.TProtocol) error + func (p *BeeswaxServiceGetLogResult) ReadField0(iprot thrift.TProtocol) error + func (p *BeeswaxServiceGetLogResult) ReadField1(iprot thrift.TProtocol) error + func (p *BeeswaxServiceGetLogResult) String() string + func (p *BeeswaxServiceGetLogResult) Write(oprot thrift.TProtocol) error + type BeeswaxServiceGetResultsMetadataArgs struct + Handle *QueryHandle + func NewBeeswaxServiceGetResultsMetadataArgs() *BeeswaxServiceGetResultsMetadataArgs + func (p *BeeswaxServiceGetResultsMetadataArgs) GetHandle() *QueryHandle + func (p *BeeswaxServiceGetResultsMetadataArgs) IsSetHandle() bool + func (p *BeeswaxServiceGetResultsMetadataArgs) Read(iprot thrift.TProtocol) error + func (p *BeeswaxServiceGetResultsMetadataArgs) ReadField1(iprot thrift.TProtocol) error + func (p *BeeswaxServiceGetResultsMetadataArgs) String() string + func (p *BeeswaxServiceGetResultsMetadataArgs) Write(oprot thrift.TProtocol) error + type BeeswaxServiceGetResultsMetadataResult struct + Error *QueryNotFoundException + Success *ResultsMetadata + func NewBeeswaxServiceGetResultsMetadataResult() *BeeswaxServiceGetResultsMetadataResult + func (p *BeeswaxServiceGetResultsMetadataResult) GetError() *QueryNotFoundException + func (p *BeeswaxServiceGetResultsMetadataResult) GetSuccess() *ResultsMetadata + func (p *BeeswaxServiceGetResultsMetadataResult) IsSetError() bool + func (p *BeeswaxServiceGetResultsMetadataResult) IsSetSuccess() bool + func (p *BeeswaxServiceGetResultsMetadataResult) Read(iprot thrift.TProtocol) error + func (p *BeeswaxServiceGetResultsMetadataResult) ReadField0(iprot thrift.TProtocol) error + func (p *BeeswaxServiceGetResultsMetadataResult) ReadField1(iprot thrift.TProtocol) error + func (p *BeeswaxServiceGetResultsMetadataResult) String() string + func (p *BeeswaxServiceGetResultsMetadataResult) Write(oprot thrift.TProtocol) error + type BeeswaxServiceGetStateArgs struct + Handle *QueryHandle + func NewBeeswaxServiceGetStateArgs() *BeeswaxServiceGetStateArgs + func (p *BeeswaxServiceGetStateArgs) GetHandle() *QueryHandle + func (p *BeeswaxServiceGetStateArgs) IsSetHandle() bool + func (p *BeeswaxServiceGetStateArgs) Read(iprot thrift.TProtocol) error + func (p *BeeswaxServiceGetStateArgs) ReadField1(iprot thrift.TProtocol) error + func (p *BeeswaxServiceGetStateArgs) String() string + func (p *BeeswaxServiceGetStateArgs) Write(oprot thrift.TProtocol) error + type BeeswaxServiceGetStateResult struct + Error *QueryNotFoundException + Success *QueryState + func NewBeeswaxServiceGetStateResult() *BeeswaxServiceGetStateResult + func (p *BeeswaxServiceGetStateResult) GetError() *QueryNotFoundException + func (p *BeeswaxServiceGetStateResult) GetSuccess() QueryState + func (p *BeeswaxServiceGetStateResult) IsSetError() bool + func (p *BeeswaxServiceGetStateResult) IsSetSuccess() bool + func (p *BeeswaxServiceGetStateResult) Read(iprot thrift.TProtocol) error + func (p *BeeswaxServiceGetStateResult) ReadField0(iprot thrift.TProtocol) error + func (p *BeeswaxServiceGetStateResult) ReadField1(iprot thrift.TProtocol) error + func (p *BeeswaxServiceGetStateResult) String() string + func (p *BeeswaxServiceGetStateResult) Write(oprot thrift.TProtocol) error + type BeeswaxServiceProcessor struct + func NewBeeswaxServiceProcessor(handler BeeswaxService) *BeeswaxServiceProcessor + func (p *BeeswaxServiceProcessor) AddToProcessorMap(key string, processor thrift.TProcessorFunction) + func (p *BeeswaxServiceProcessor) GetProcessorFunction(key string) (processor thrift.TProcessorFunction, ok bool) + func (p *BeeswaxServiceProcessor) Process(ctx context.Context, iprot, oprot thrift.TProtocol) (success bool, err thrift.TException) + func (p *BeeswaxServiceProcessor) ProcessorMap() map[string]thrift.TProcessorFunction + type BeeswaxServiceQueryArgs struct + Query *Query + func NewBeeswaxServiceQueryArgs() *BeeswaxServiceQueryArgs + func (p *BeeswaxServiceQueryArgs) GetQuery() *Query + func (p *BeeswaxServiceQueryArgs) IsSetQuery() bool + func (p *BeeswaxServiceQueryArgs) Read(iprot thrift.TProtocol) error + func (p *BeeswaxServiceQueryArgs) ReadField1(iprot thrift.TProtocol) error + func (p *BeeswaxServiceQueryArgs) String() string + func (p *BeeswaxServiceQueryArgs) Write(oprot thrift.TProtocol) error + type BeeswaxServiceQueryResult struct + Error *BeeswaxException + Success *QueryHandle + func NewBeeswaxServiceQueryResult() *BeeswaxServiceQueryResult + func (p *BeeswaxServiceQueryResult) GetError() *BeeswaxException + func (p *BeeswaxServiceQueryResult) GetSuccess() *QueryHandle + func (p *BeeswaxServiceQueryResult) IsSetError() bool + func (p *BeeswaxServiceQueryResult) IsSetSuccess() bool + func (p *BeeswaxServiceQueryResult) Read(iprot thrift.TProtocol) error + func (p *BeeswaxServiceQueryResult) ReadField0(iprot thrift.TProtocol) error + func (p *BeeswaxServiceQueryResult) ReadField1(iprot thrift.TProtocol) error + func (p *BeeswaxServiceQueryResult) String() string + func (p *BeeswaxServiceQueryResult) Write(oprot thrift.TProtocol) error + type ConfigVariable struct + Description string + Key string + Value string + func NewConfigVariable() *ConfigVariable + func (p *ConfigVariable) GetDescription() string + func (p *ConfigVariable) GetKey() string + func (p *ConfigVariable) GetValue() string + func (p *ConfigVariable) Read(iprot thrift.TProtocol) error + func (p *ConfigVariable) ReadField1(iprot thrift.TProtocol) error + func (p *ConfigVariable) ReadField2(iprot thrift.TProtocol) error + func (p *ConfigVariable) ReadField3(iprot thrift.TProtocol) error + func (p *ConfigVariable) String() string + func (p *ConfigVariable) Write(oprot thrift.TProtocol) error + type LogContextId string + func LogContextIdPtr(v LogContextId) *LogContextId + type Query struct + Configuration []string + HadoopUser string + Query string + var BeeswaxServiceExecuteAndWaitArgs_Query_DEFAULT *Query + var BeeswaxServiceExplainArgs_Query_DEFAULT *Query + var BeeswaxServiceQueryArgs_Query_DEFAULT *Query + func NewQuery() *Query + func (p *Query) GetConfiguration() []string + func (p *Query) GetHadoopUser() string + func (p *Query) GetQuery() string + func (p *Query) Read(iprot thrift.TProtocol) error + func (p *Query) ReadField1(iprot thrift.TProtocol) error + func (p *Query) ReadField3(iprot thrift.TProtocol) error + func (p *Query) ReadField4(iprot thrift.TProtocol) error + func (p *Query) String() string + func (p *Query) Write(oprot thrift.TProtocol) error + type QueryExplanation struct + Textual string + var BeeswaxServiceExplainResult_Success_DEFAULT *QueryExplanation + func NewQueryExplanation() *QueryExplanation + func (p *QueryExplanation) GetTextual() string + func (p *QueryExplanation) Read(iprot thrift.TProtocol) error + func (p *QueryExplanation) ReadField1(iprot thrift.TProtocol) error + func (p *QueryExplanation) String() string + func (p *QueryExplanation) Write(oprot thrift.TProtocol) error + type QueryHandle struct + ID string + LogContext LogContextId + var BeeswaxException_Handle_DEFAULT *QueryHandle + var BeeswaxServiceCloseArgs_Handle_DEFAULT *QueryHandle + var BeeswaxServiceExecuteAndWaitResult_Success_DEFAULT *QueryHandle + var BeeswaxServiceFetchArgs_QueryID_DEFAULT *QueryHandle + var BeeswaxServiceGetResultsMetadataArgs_Handle_DEFAULT *QueryHandle + var BeeswaxServiceGetStateArgs_Handle_DEFAULT *QueryHandle + var BeeswaxServiceQueryResult_Success_DEFAULT *QueryHandle + func NewQueryHandle() *QueryHandle + func (p *QueryHandle) GetID() string + func (p *QueryHandle) GetLogContext() LogContextId + func (p *QueryHandle) Read(iprot thrift.TProtocol) error + func (p *QueryHandle) ReadField1(iprot thrift.TProtocol) error + func (p *QueryHandle) ReadField2(iprot thrift.TProtocol) error + func (p *QueryHandle) String() string + func (p *QueryHandle) Write(oprot thrift.TProtocol) error + type QueryNotFoundException struct + var BeeswaxServiceCloseResult_Error_DEFAULT *QueryNotFoundException + var BeeswaxServiceFetchResult_Error_DEFAULT *QueryNotFoundException + var BeeswaxServiceGetLogResult_Error_DEFAULT *QueryNotFoundException + var BeeswaxServiceGetResultsMetadataResult_Error_DEFAULT *QueryNotFoundException + var BeeswaxServiceGetStateResult_Error_DEFAULT *QueryNotFoundException + func NewQueryNotFoundException() *QueryNotFoundException + func (p *QueryNotFoundException) Error() string + func (p *QueryNotFoundException) Read(iprot thrift.TProtocol) error + func (p *QueryNotFoundException) String() string + func (p *QueryNotFoundException) Write(oprot thrift.TProtocol) error + type QueryState int64 + const QueryState_COMPILED + const QueryState_CREATED + const QueryState_EXCEPTION + const QueryState_FINISHED + const QueryState_INITIALIZED + const QueryState_RUNNING + var BeeswaxServiceGetStateResult_Success_DEFAULT QueryState + func QueryStateFromString(s string) (QueryState, error) + func QueryStatePtr(v QueryState) *QueryState + func (p *QueryState) Scan(value interface{}) error + func (p *QueryState) UnmarshalText(text []byte) error + func (p *QueryState) Value() (driver.Value, error) + func (p QueryState) MarshalText() ([]byte, error) + func (p QueryState) String() string + type Results struct + Columns []string + Data []string + HasMore bool + Ready bool + StartRow int64 + var BeeswaxServiceFetchResult_Success_DEFAULT *Results + func NewResults() *Results + func (p *Results) GetColumns() []string + func (p *Results) GetData() []string + func (p *Results) GetHasMore() bool + func (p *Results) GetReady() bool + func (p *Results) GetStartRow() int64 + func (p *Results) Read(iprot thrift.TProtocol) error + func (p *Results) ReadField1(iprot thrift.TProtocol) error + func (p *Results) ReadField2(iprot thrift.TProtocol) error + func (p *Results) ReadField3(iprot thrift.TProtocol) error + func (p *Results) ReadField4(iprot thrift.TProtocol) error + func (p *Results) ReadField5(iprot thrift.TProtocol) error + func (p *Results) String() string + func (p *Results) Write(oprot thrift.TProtocol) error + type ResultsMetadata struct + Delim string + InTablename string + Schema *hive_metastore.Schema + TableDir string + var BeeswaxServiceGetResultsMetadataResult_Success_DEFAULT *ResultsMetadata + func NewResultsMetadata() *ResultsMetadata + func (p *ResultsMetadata) GetDelim() string + func (p *ResultsMetadata) GetInTablename() string + func (p *ResultsMetadata) GetSchema() *hive_metastore.Schema + func (p *ResultsMetadata) GetTableDir() string + func (p *ResultsMetadata) IsSetSchema() bool + func (p *ResultsMetadata) Read(iprot thrift.TProtocol) error + func (p *ResultsMetadata) ReadField1(iprot thrift.TProtocol) error + func (p *ResultsMetadata) ReadField2(iprot thrift.TProtocol) error + func (p *ResultsMetadata) ReadField3(iprot thrift.TProtocol) error + func (p *ResultsMetadata) ReadField4(iprot thrift.TProtocol) error + func (p *ResultsMetadata) String() string + func (p *ResultsMetadata) Write(oprot thrift.TProtocol) error Incompatible versions in this module v2.1.0+incompatible Jan 13, 2021 v2.0.0+incompatible May 26, 2019
Go to main page