beeswax

package
v0.0.0-...-091d07d Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jun 26, 2020 License: MIT Imports: 8 Imported by: 5

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var BeeswaxException_ErrorCode_DEFAULT int32 = 0
View Source 
var BeeswaxException_SQLState_DEFAULT string = "     "
View Source 
var BeeswaxServiceDumpConfigResult_Success_DEFAULT string
View Source 
var BeeswaxServiceEchoResult_Success_DEFAULT string
View Source 
var BeeswaxServiceGetDefaultConfigurationResult_Success_DEFAULT []*ConfigVariable
View Source 
var BeeswaxServiceGetLogResult_Success_DEFAULT string
View Source 
var GoUnusedProtection__ int
View Source 
var ResultsMetadata_Schema_DEFAULT *hive_metastore.Schema

Functions

This section is empty.

Types

type BeeswaxException 

type BeeswaxException struct {
	Message    string       `thrift:"message,1" db:"message" json:"message"`
	LogContext LogContextId `thrift:"log_context,2" db:"log_context" json:"log_context"`
	Handle     *QueryHandle `thrift:"handle,3" db:"handle" json:"handle"`
	ErrorCode  int32        `thrift:"errorCode,4" db:"errorCode" json:"errorCode,omitempty"`
	SQLState   string       `thrift:"SQLState,5" db:"SQLState" json:"SQLState,omitempty"`
}

Attributes:

  • Message
  • LogContext
  • Handle
  • ErrorCode
  • SQLState
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 

func NewBeeswaxException() *BeeswaxException

func (*BeeswaxException) Error 

func (p *BeeswaxException) Error() string

func (*BeeswaxException) GetErrorCode 

func (p *BeeswaxException) GetErrorCode() int32

func (*BeeswaxException) GetHandle 

func (p *BeeswaxException) GetHandle() *QueryHandle

func (*BeeswaxException) GetLogContext 

func (p *BeeswaxException) GetLogContext() LogContextId

func (*BeeswaxException) GetMessage 

func (p *BeeswaxException) GetMessage() string

func (*BeeswaxException) GetSQLState 

func (p *BeeswaxException) GetSQLState() string

func (*BeeswaxException) IsSetErrorCode 

func (p *BeeswaxException) IsSetErrorCode() bool

func (*BeeswaxException) IsSetHandle 

func (p *BeeswaxException) IsSetHandle() bool

func (*BeeswaxException) IsSetSQLState 

func (p *BeeswaxException) IsSetSQLState() bool

func (*BeeswaxException) Read 

func (p *BeeswaxException) Read(iprot thrift.TProtocol) error

func (*BeeswaxException) ReadField1 

func (p *BeeswaxException) ReadField1(iprot thrift.TProtocol) error

func (*BeeswaxException) ReadField2 

func (p *BeeswaxException) ReadField2(iprot thrift.TProtocol) error

func (*BeeswaxException) ReadField3 

func (p *BeeswaxException) ReadField3(iprot thrift.TProtocol) error

func (*BeeswaxException) ReadField4 

func (p *BeeswaxException) ReadField4(iprot thrift.TProtocol) error

func (*BeeswaxException) ReadField5 

func (p *BeeswaxException) ReadField5(iprot thrift.TProtocol) error

func (*BeeswaxException) String 

func (p *BeeswaxException) String() string

func (*BeeswaxException) Write 

func (p *BeeswaxException) Write(oprot thrift.TProtocol) error

type BeeswaxService 

type BeeswaxService interface {
	// Submit a query and return a handle (QueryHandle). The query runs asynchronously.
	//
	// Parameters:
	//  - Query
	Query(ctx context.Context, query *Query) (r *QueryHandle, err error)
	// run a query synchronously and return a handle (QueryHandle).
	//
	// Parameters:
	//  - Query
	//  - ClientCtx
	ExecuteAndWait(ctx context.Context, query *Query, clientCtx LogContextId) (r *QueryHandle, err error)
	// Get the query plan for a query.
	//
	// Parameters:
	//  - Query
	Explain(ctx context.Context, query *Query) (r *QueryExplanation, err error)
	// Get the results of a query. This is non-blocking. Caller should check
	// Results.ready to determine if the results are in yet. The call requests
	// the batch size of fetch.
	//
	// Parameters:
	//  - QueryID
	//  - StartOver
	//  - FetchSize
	Fetch(ctx context.Context, query_id *QueryHandle, start_over bool, fetch_size int32) (r *Results, err error)
	// Get the state of the query
	//
	// Parameters:
	//  - Handle
	GetState(ctx context.Context, handle *QueryHandle) (r QueryState, err error)
	// Get the result metadata
	//
	// Parameters:
	//  - Handle
	GetResultsMetadata(ctx context.Context, handle *QueryHandle) (r *ResultsMetadata, err error)
	// Used to test connection to server.  A "noop" command.
	//
	// Parameters:
	//  - S
	Echo(ctx context.Context, s string) (r string, err error)
	// Returns a string representation of the configuration object being used.
	// Handy for debugging.
	DumpConfig(ctx context.Context) (r string, err error)
	// Get the log messages related to the given context.
	//
	// Parameters:
	//  - Context
	GetLog(ctx context.Context, context LogContextId) (r string, err error)
	// Parameters:
	//  - IncludeHadoop
	GetDefaultConfiguration(ctx context.Context, include_hadoop bool) (r []*ConfigVariable, err error)
	// Parameters:
	//  - Handle
	Close(ctx context.Context, handle *QueryHandle) (err error)
	// Parameters:
	//  - LogContext
	Clean(ctx context.Context, log_context LogContextId) (err error)
}

type BeeswaxServiceCleanArgs 

type BeeswaxServiceCleanArgs struct {
	LogContext LogContextId `thrift:"log_context,1" db:"log_context" json:"log_context"`
}

Attributes:

  • LogContext

func NewBeeswaxServiceCleanArgs 

func NewBeeswaxServiceCleanArgs() *BeeswaxServiceCleanArgs

func (*BeeswaxServiceCleanArgs) GetLogContext 

func (p *BeeswaxServiceCleanArgs) GetLogContext() LogContextId

func (*BeeswaxServiceCleanArgs) Read 

func (p *BeeswaxServiceCleanArgs) Read(iprot thrift.TProtocol) error

func (*BeeswaxServiceCleanArgs) ReadField1 

func (p *BeeswaxServiceCleanArgs) ReadField1(iprot thrift.TProtocol) error

func (*BeeswaxServiceCleanArgs) String 

func (p *BeeswaxServiceCleanArgs) String() string

func (*BeeswaxServiceCleanArgs) Write 

func (p *BeeswaxServiceCleanArgs) Write(oprot thrift.TProtocol) error

type BeeswaxServiceCleanResult 

type BeeswaxServiceCleanResult struct {
}

func NewBeeswaxServiceCleanResult 

func NewBeeswaxServiceCleanResult() *BeeswaxServiceCleanResult

func (*BeeswaxServiceCleanResult) Read 

func (p *BeeswaxServiceCleanResult) Read(iprot thrift.TProtocol) error

func (*BeeswaxServiceCleanResult) String 

func (p *BeeswaxServiceCleanResult) String() string

func (*BeeswaxServiceCleanResult) Write 

func (p *BeeswaxServiceCleanResult) Write(oprot thrift.TProtocol) error

type BeeswaxServiceClient 

type BeeswaxServiceClient struct {
	// contains filtered or unexported fields
}

func NewBeeswaxServiceClient 

func NewBeeswaxServiceClient(c thrift.TClient) *BeeswaxServiceClient

func NewBeeswaxServiceClientFactory 

func NewBeeswaxServiceClientFactory(t thrift.TTransport, f thrift.TProtocolFactory) *BeeswaxServiceClient

func NewBeeswaxServiceClientProtocol 

func NewBeeswaxServiceClientProtocol(t thrift.TTransport, iprot thrift.TProtocol, oprot thrift.TProtocol) *BeeswaxServiceClient

func (*BeeswaxServiceClient) Clean 

func (p *BeeswaxServiceClient) Clean(ctx context.Context, log_context LogContextId) (err error)

Parameters:

  • LogContext

func (*BeeswaxServiceClient) Client_ 

func (p *BeeswaxServiceClient) Client_() thrift.TClient

func (*BeeswaxServiceClient) Close 

func (p *BeeswaxServiceClient) Close(ctx context.Context, handle *QueryHandle) (err error)

Parameters:

  • Handle

func (*BeeswaxServiceClient) DumpConfig 

func (p *BeeswaxServiceClient) DumpConfig(ctx context.Context) (r string, err error)

Returns a string representation of the configuration object being used. Handy for debugging.

func (*BeeswaxServiceClient) Echo 

func (p *BeeswaxServiceClient) Echo(ctx context.Context, s string) (r string, err error)

Used to test connection to server. A "noop" command.

Parameters:

  • S

func (*BeeswaxServiceClient) ExecuteAndWait 

func (p *BeeswaxServiceClient) ExecuteAndWait(ctx context.Context, query *Query, clientCtx LogContextId) (r *QueryHandle, err error)

run a query synchronously and return a handle (QueryHandle).

Parameters:

  • Query
  • ClientCtx

func (*BeeswaxServiceClient) Explain 

func (p *BeeswaxServiceClient) Explain(ctx context.Context, query *Query) (r *QueryExplanation, err error)

Get the query plan for a query.

Parameters:

  • Query

func (*BeeswaxServiceClient) Fetch 

func (p *BeeswaxServiceClient) Fetch(ctx context.Context, query_id *QueryHandle, start_over bool, fetch_size int32) (r *Results, err error)

Get the results of a query. This is non-blocking. Caller should check Results.ready to determine if the results are in yet. The call requests the batch size of fetch.

Parameters:

  • QueryID
  • StartOver
  • FetchSize

func (*BeeswaxServiceClient) GetDefaultConfiguration 

func (p *BeeswaxServiceClient) GetDefaultConfiguration(ctx context.Context, include_hadoop bool) (r []*ConfigVariable, err error)

Parameters:

  • IncludeHadoop

func (*BeeswaxServiceClient) GetLog 

func (p *BeeswaxServiceClient) GetLog(ctx context.Context, context LogContextId) (r string, err error)

Get the log messages related to the given context.

Parameters:

  • Context

func (*BeeswaxServiceClient) GetResultsMetadata 

func (p *BeeswaxServiceClient) GetResultsMetadata(ctx context.Context, handle *QueryHandle) (r *ResultsMetadata, err error)

Get the result metadata

Parameters:

  • Handle

func (*BeeswaxServiceClient) GetState 

func (p *BeeswaxServiceClient) GetState(ctx context.Context, handle *QueryHandle) (r QueryState, err error)

Get the state of the query

Parameters:

  • Handle

func (*BeeswaxServiceClient) Query 

func (p *BeeswaxServiceClient) Query(ctx context.Context, query *Query) (r *QueryHandle, err error)

Submit a query and return a handle (QueryHandle). The query runs asynchronously.

Parameters:

  • Query

type BeeswaxServiceCloseArgs 

type BeeswaxServiceCloseArgs struct {
	Handle *QueryHandle `thrift:"handle,1" db:"handle" json:"handle"`
}

Attributes:

  • Handle

func NewBeeswaxServiceCloseArgs 

func NewBeeswaxServiceCloseArgs() *BeeswaxServiceCloseArgs

func (*BeeswaxServiceCloseArgs) GetHandle 

func (p *BeeswaxServiceCloseArgs) GetHandle() *QueryHandle

func (*BeeswaxServiceCloseArgs) IsSetHandle 

func (p *BeeswaxServiceCloseArgs) IsSetHandle() bool

func (*BeeswaxServiceCloseArgs) Read 

func (p *BeeswaxServiceCloseArgs) Read(iprot thrift.TProtocol) error

func (*BeeswaxServiceCloseArgs) ReadField1 

func (p *BeeswaxServiceCloseArgs) ReadField1(iprot thrift.TProtocol) error

func (*BeeswaxServiceCloseArgs) String 

func (p *BeeswaxServiceCloseArgs) String() string

func (*BeeswaxServiceCloseArgs) Write 

func (p *BeeswaxServiceCloseArgs) Write(oprot thrift.TProtocol) error

type BeeswaxServiceCloseResult 

type BeeswaxServiceCloseResult struct {
	Error  *QueryNotFoundException `thrift:"error,1" db:"error" json:"error,omitempty"`
	Error2 *BeeswaxException       `thrift:"error2,2" db:"error2" json:"error2,omitempty"`
}

Attributes:

  • Error
  • Error2

func NewBeeswaxServiceCloseResult 

func NewBeeswaxServiceCloseResult() *BeeswaxServiceCloseResult

func (*BeeswaxServiceCloseResult) GetError 

func (p *BeeswaxServiceCloseResult) GetError() *QueryNotFoundException

func (*BeeswaxServiceCloseResult) GetError2 

func (p *BeeswaxServiceCloseResult) GetError2() *BeeswaxException

func (*BeeswaxServiceCloseResult) IsSetError 

func (p *BeeswaxServiceCloseResult) IsSetError() bool

func (*BeeswaxServiceCloseResult) IsSetError2 

func (p *BeeswaxServiceCloseResult) IsSetError2() bool

func (*BeeswaxServiceCloseResult) Read 

func (p *BeeswaxServiceCloseResult) Read(iprot thrift.TProtocol) error

func (*BeeswaxServiceCloseResult) ReadField1 

func (p *BeeswaxServiceCloseResult) ReadField1(iprot thrift.TProtocol) error

func (*BeeswaxServiceCloseResult) ReadField2 

func (p *BeeswaxServiceCloseResult) ReadField2(iprot thrift.TProtocol) error

func (*BeeswaxServiceCloseResult) String 

func (p *BeeswaxServiceCloseResult) String() string

func (*BeeswaxServiceCloseResult) Write 

func (p *BeeswaxServiceCloseResult) Write(oprot thrift.TProtocol) error

type BeeswaxServiceDumpConfigArgs 

type BeeswaxServiceDumpConfigArgs struct {
}

func NewBeeswaxServiceDumpConfigArgs 

func NewBeeswaxServiceDumpConfigArgs() *BeeswaxServiceDumpConfigArgs

func (*BeeswaxServiceDumpConfigArgs) Read 

func (p *BeeswaxServiceDumpConfigArgs) Read(iprot thrift.TProtocol) error

func (*BeeswaxServiceDumpConfigArgs) String 

func (p *BeeswaxServiceDumpConfigArgs) String() string

func (*BeeswaxServiceDumpConfigArgs) Write 

func (p *BeeswaxServiceDumpConfigArgs) Write(oprot thrift.TProtocol) error

type BeeswaxServiceDumpConfigResult 

type BeeswaxServiceDumpConfigResult struct {
	Success *string `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewBeeswaxServiceDumpConfigResult 

func NewBeeswaxServiceDumpConfigResult() *BeeswaxServiceDumpConfigResult

func (*BeeswaxServiceDumpConfigResult) GetSuccess 

func (p *BeeswaxServiceDumpConfigResult) GetSuccess() string

func (*BeeswaxServiceDumpConfigResult) IsSetSuccess 

func (p *BeeswaxServiceDumpConfigResult) IsSetSuccess() bool

func (*BeeswaxServiceDumpConfigResult) Read 

func (p *BeeswaxServiceDumpConfigResult) Read(iprot thrift.TProtocol) error

func (*BeeswaxServiceDumpConfigResult) ReadField0 

func (p *BeeswaxServiceDumpConfigResult) ReadField0(iprot thrift.TProtocol) error

func (*BeeswaxServiceDumpConfigResult) String 

func (p *BeeswaxServiceDumpConfigResult) String() string

func (*BeeswaxServiceDumpConfigResult) Write 

func (p *BeeswaxServiceDumpConfigResult) Write(oprot thrift.TProtocol) error

type BeeswaxServiceEchoArgs 

type BeeswaxServiceEchoArgs struct {
	S string `thrift:"s,1" db:"s" json:"s"`
}

Attributes:

  • S

func NewBeeswaxServiceEchoArgs 

func NewBeeswaxServiceEchoArgs() *BeeswaxServiceEchoArgs

func (*BeeswaxServiceEchoArgs) GetS 

func (p *BeeswaxServiceEchoArgs) GetS() string

func (*BeeswaxServiceEchoArgs) Read 

func (p *BeeswaxServiceEchoArgs) Read(iprot thrift.TProtocol) error

func (*BeeswaxServiceEchoArgs) ReadField1 

func (p *BeeswaxServiceEchoArgs) ReadField1(iprot thrift.TProtocol) error

func (*BeeswaxServiceEchoArgs) String 

func (p *BeeswaxServiceEchoArgs) String() string

func (*BeeswaxServiceEchoArgs) Write 

func (p *BeeswaxServiceEchoArgs) Write(oprot thrift.TProtocol) error

type BeeswaxServiceEchoResult 

type BeeswaxServiceEchoResult struct {
	Success *string `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewBeeswaxServiceEchoResult 

func NewBeeswaxServiceEchoResult() *BeeswaxServiceEchoResult

func (*BeeswaxServiceEchoResult) GetSuccess 

func (p *BeeswaxServiceEchoResult) GetSuccess() string

func (*BeeswaxServiceEchoResult) IsSetSuccess 

func (p *BeeswaxServiceEchoResult) IsSetSuccess() bool

func (*BeeswaxServiceEchoResult) Read 

func (p *BeeswaxServiceEchoResult) Read(iprot thrift.TProtocol) error

func (*BeeswaxServiceEchoResult) ReadField0 

func (p *BeeswaxServiceEchoResult) ReadField0(iprot thrift.TProtocol) error

func (*BeeswaxServiceEchoResult) String 

func (p *BeeswaxServiceEchoResult) String() string

func (*BeeswaxServiceEchoResult) Write 

func (p *BeeswaxServiceEchoResult) Write(oprot thrift.TProtocol) error

type BeeswaxServiceExecuteAndWaitArgs 

type BeeswaxServiceExecuteAndWaitArgs struct {
	Query     *Query       `thrift:"query,1" db:"query" json:"query"`
	ClientCtx LogContextId `thrift:"clientCtx,2" db:"clientCtx" json:"clientCtx"`
}

Attributes:

  • Query
  • ClientCtx

func NewBeeswaxServiceExecuteAndWaitArgs 

func NewBeeswaxServiceExecuteAndWaitArgs() *BeeswaxServiceExecuteAndWaitArgs

func (*BeeswaxServiceExecuteAndWaitArgs) GetClientCtx 

func (p *BeeswaxServiceExecuteAndWaitArgs) GetClientCtx() LogContextId

func (*BeeswaxServiceExecuteAndWaitArgs) GetQuery 

func (p *BeeswaxServiceExecuteAndWaitArgs) GetQuery() *Query

func (*BeeswaxServiceExecuteAndWaitArgs) IsSetQuery 

func (p *BeeswaxServiceExecuteAndWaitArgs) IsSetQuery() bool

func (*BeeswaxServiceExecuteAndWaitArgs) Read 

func (p *BeeswaxServiceExecuteAndWaitArgs) Read(iprot thrift.TProtocol) error

func (*BeeswaxServiceExecuteAndWaitArgs) ReadField1 

func (p *BeeswaxServiceExecuteAndWaitArgs) ReadField1(iprot thrift.TProtocol) error

func (*BeeswaxServiceExecuteAndWaitArgs) ReadField2 

func (p *BeeswaxServiceExecuteAndWaitArgs) ReadField2(iprot thrift.TProtocol) error

func (*BeeswaxServiceExecuteAndWaitArgs) String 

func (p *BeeswaxServiceExecuteAndWaitArgs) String() string

func (*BeeswaxServiceExecuteAndWaitArgs) Write 

func (p *BeeswaxServiceExecuteAndWaitArgs) Write(oprot thrift.TProtocol) error

type BeeswaxServiceExecuteAndWaitResult 

type BeeswaxServiceExecuteAndWaitResult struct {
	Success *QueryHandle      `thrift:"success,0" db:"success" json:"success,omitempty"`
	Error   *BeeswaxException `thrift:"error,1" db:"error" json:"error,omitempty"`
}

Attributes:

  • Success
  • Error

func NewBeeswaxServiceExecuteAndWaitResult 

func NewBeeswaxServiceExecuteAndWaitResult() *BeeswaxServiceExecuteAndWaitResult

func (*BeeswaxServiceExecuteAndWaitResult) GetError 

func (p *BeeswaxServiceExecuteAndWaitResult) GetError() *BeeswaxException

func (*BeeswaxServiceExecuteAndWaitResult) GetSuccess 

func (p *BeeswaxServiceExecuteAndWaitResult) GetSuccess() *QueryHandle

func (*BeeswaxServiceExecuteAndWaitResult) IsSetError 

func (p *BeeswaxServiceExecuteAndWaitResult) IsSetError() bool

func (*BeeswaxServiceExecuteAndWaitResult) IsSetSuccess 

func (p *BeeswaxServiceExecuteAndWaitResult) IsSetSuccess() bool

func (*BeeswaxServiceExecuteAndWaitResult) Read 

func (p *BeeswaxServiceExecuteAndWaitResult) Read(iprot thrift.TProtocol) error

func (*BeeswaxServiceExecuteAndWaitResult) ReadField0 

func (p *BeeswaxServiceExecuteAndWaitResult) ReadField0(iprot thrift.TProtocol) error

func (*BeeswaxServiceExecuteAndWaitResult) ReadField1 

func (p *BeeswaxServiceExecuteAndWaitResult) ReadField1(iprot thrift.TProtocol) error

func (*BeeswaxServiceExecuteAndWaitResult) String 

func (p *BeeswaxServiceExecuteAndWaitResult) String() string

func (*BeeswaxServiceExecuteAndWaitResult) Write 

func (p *BeeswaxServiceExecuteAndWaitResult) Write(oprot thrift.TProtocol) error

type BeeswaxServiceExplainArgs 

type BeeswaxServiceExplainArgs struct {
	Query *Query `thrift:"query,1" db:"query" json:"query"`
}

Attributes:

  • Query

func NewBeeswaxServiceExplainArgs 

func NewBeeswaxServiceExplainArgs() *BeeswaxServiceExplainArgs

func (*BeeswaxServiceExplainArgs) GetQuery 

func (p *BeeswaxServiceExplainArgs) GetQuery() *Query

func (*BeeswaxServiceExplainArgs) IsSetQuery 

func (p *BeeswaxServiceExplainArgs) IsSetQuery() bool

func (*BeeswaxServiceExplainArgs) Read 

func (p *BeeswaxServiceExplainArgs) Read(iprot thrift.TProtocol) error

func (*BeeswaxServiceExplainArgs) ReadField1 

func (p *BeeswaxServiceExplainArgs) ReadField1(iprot thrift.TProtocol) error

func (*BeeswaxServiceExplainArgs) String 

func (p *BeeswaxServiceExplainArgs) String() string

func (*BeeswaxServiceExplainArgs) Write 

func (p *BeeswaxServiceExplainArgs) Write(oprot thrift.TProtocol) error

type BeeswaxServiceExplainResult 

type BeeswaxServiceExplainResult struct {
	Success *QueryExplanation `thrift:"success,0" db:"success" json:"success,omitempty"`
	Error   *BeeswaxException `thrift:"error,1" db:"error" json:"error,omitempty"`
}

Attributes:

  • Success
  • Error

func NewBeeswaxServiceExplainResult 

func NewBeeswaxServiceExplainResult() *BeeswaxServiceExplainResult

func (*BeeswaxServiceExplainResult) GetError 

func (p *BeeswaxServiceExplainResult) GetError() *BeeswaxException

func (*BeeswaxServiceExplainResult) GetSuccess 

func (p *BeeswaxServiceExplainResult) GetSuccess() *QueryExplanation

func (*BeeswaxServiceExplainResult) IsSetError 

func (p *BeeswaxServiceExplainResult) IsSetError() bool

func (*BeeswaxServiceExplainResult) IsSetSuccess 

func (p *BeeswaxServiceExplainResult) IsSetSuccess() bool

func (*BeeswaxServiceExplainResult) Read 

func (p *BeeswaxServiceExplainResult) Read(iprot thrift.TProtocol) error

func (*BeeswaxServiceExplainResult) ReadField0 

func (p *BeeswaxServiceExplainResult) ReadField0(iprot thrift.TProtocol) error

func (*BeeswaxServiceExplainResult) ReadField1 

func (p *BeeswaxServiceExplainResult) ReadField1(iprot thrift.TProtocol) error

func (*BeeswaxServiceExplainResult) String 

func (p *BeeswaxServiceExplainResult) String() string

func (*BeeswaxServiceExplainResult) Write 

func (p *BeeswaxServiceExplainResult) Write(oprot thrift.TProtocol) error

type BeeswaxServiceFetchArgs 

type BeeswaxServiceFetchArgs struct {
	QueryID   *QueryHandle `thrift:"query_id,1" db:"query_id" json:"query_id"`
	StartOver bool         `thrift:"start_over,2" db:"start_over" json:"start_over"`
	FetchSize int32        `thrift:"fetch_size,3" db:"fetch_size" json:"fetch_size"`
}

Attributes:

  • QueryID
  • StartOver
  • FetchSize

func NewBeeswaxServiceFetchArgs 

func NewBeeswaxServiceFetchArgs() *BeeswaxServiceFetchArgs

func (*BeeswaxServiceFetchArgs) GetFetchSize 

func (p *BeeswaxServiceFetchArgs) GetFetchSize() int32

func (*BeeswaxServiceFetchArgs) GetQueryID 

func (p *BeeswaxServiceFetchArgs) GetQueryID() *QueryHandle

func (*BeeswaxServiceFetchArgs) GetStartOver 

func (p *BeeswaxServiceFetchArgs) GetStartOver() bool

func (*BeeswaxServiceFetchArgs) IsSetQueryID 

func (p *BeeswaxServiceFetchArgs) IsSetQueryID() bool

func (*BeeswaxServiceFetchArgs) Read 

func (p *BeeswaxServiceFetchArgs) Read(iprot thrift.TProtocol) error

func (*BeeswaxServiceFetchArgs) ReadField1 

func (p *BeeswaxServiceFetchArgs) ReadField1(iprot thrift.TProtocol) error

func (*BeeswaxServiceFetchArgs) ReadField2 

func (p *BeeswaxServiceFetchArgs) ReadField2(iprot thrift.TProtocol) error

func (*BeeswaxServiceFetchArgs) ReadField3 

func (p *BeeswaxServiceFetchArgs) ReadField3(iprot thrift.TProtocol) error

func (*BeeswaxServiceFetchArgs) String 

func (p *BeeswaxServiceFetchArgs) String() string

func (*BeeswaxServiceFetchArgs) Write 

func (p *BeeswaxServiceFetchArgs) Write(oprot thrift.TProtocol) error

type BeeswaxServiceFetchResult 

type BeeswaxServiceFetchResult struct {
	Success *Results                `thrift:"success,0" db:"success" json:"success,omitempty"`
	Error   *QueryNotFoundException `thrift:"error,1" db:"error" json:"error,omitempty"`
	Error2  *BeeswaxException       `thrift:"error2,2" db:"error2" json:"error2,omitempty"`
}

Attributes:

  • Success
  • Error
  • Error2

func NewBeeswaxServiceFetchResult 

func NewBeeswaxServiceFetchResult() *BeeswaxServiceFetchResult

func (*BeeswaxServiceFetchResult) GetError 

func (p *BeeswaxServiceFetchResult) GetError() *QueryNotFoundException

func (*BeeswaxServiceFetchResult) GetError2 

func (p *BeeswaxServiceFetchResult) GetError2() *BeeswaxException

func (*BeeswaxServiceFetchResult) GetSuccess 

func (p *BeeswaxServiceFetchResult) GetSuccess() *Results

func (*BeeswaxServiceFetchResult) IsSetError 

func (p *BeeswaxServiceFetchResult) IsSetError() bool

func (*BeeswaxServiceFetchResult) IsSetError2 

func (p *BeeswaxServiceFetchResult) IsSetError2() bool

func (*BeeswaxServiceFetchResult) IsSetSuccess 

func (p *BeeswaxServiceFetchResult) IsSetSuccess() bool

func (*BeeswaxServiceFetchResult) Read 

func (p *BeeswaxServiceFetchResult) Read(iprot thrift.TProtocol) error

func (*BeeswaxServiceFetchResult) ReadField0 

func (p *BeeswaxServiceFetchResult) ReadField0(iprot thrift.TProtocol) error

func (*BeeswaxServiceFetchResult) ReadField1 

func (p *BeeswaxServiceFetchResult) ReadField1(iprot thrift.TProtocol) error

func (*BeeswaxServiceFetchResult) ReadField2 

func (p *BeeswaxServiceFetchResult) ReadField2(iprot thrift.TProtocol) error

func (*BeeswaxServiceFetchResult) String 

func (p *BeeswaxServiceFetchResult) String() string

func (*BeeswaxServiceFetchResult) Write 

func (p *BeeswaxServiceFetchResult) Write(oprot thrift.TProtocol) error

type BeeswaxServiceGetDefaultConfigurationArgs 

type BeeswaxServiceGetDefaultConfigurationArgs struct {
	IncludeHadoop bool `thrift:"include_hadoop,1" db:"include_hadoop" json:"include_hadoop"`
}

Attributes:

  • IncludeHadoop

func NewBeeswaxServiceGetDefaultConfigurationArgs 

func NewBeeswaxServiceGetDefaultConfigurationArgs() *BeeswaxServiceGetDefaultConfigurationArgs

func (*BeeswaxServiceGetDefaultConfigurationArgs) GetIncludeHadoop 

func (p *BeeswaxServiceGetDefaultConfigurationArgs) GetIncludeHadoop() bool

func (*BeeswaxServiceGetDefaultConfigurationArgs) Read 

func (p *BeeswaxServiceGetDefaultConfigurationArgs) Read(iprot thrift.TProtocol) error

func (*BeeswaxServiceGetDefaultConfigurationArgs) ReadField1 

func (p *BeeswaxServiceGetDefaultConfigurationArgs) ReadField1(iprot thrift.TProtocol) error

func (*BeeswaxServiceGetDefaultConfigurationArgs) String 

func (p *BeeswaxServiceGetDefaultConfigurationArgs) String() string

func (*BeeswaxServiceGetDefaultConfigurationArgs) Write 

func (p *BeeswaxServiceGetDefaultConfigurationArgs) Write(oprot thrift.TProtocol) error

type BeeswaxServiceGetDefaultConfigurationResult 

type BeeswaxServiceGetDefaultConfigurationResult struct {
	Success []*ConfigVariable `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewBeeswaxServiceGetDefaultConfigurationResult 

func NewBeeswaxServiceGetDefaultConfigurationResult() *BeeswaxServiceGetDefaultConfigurationResult

func (*BeeswaxServiceGetDefaultConfigurationResult) GetSuccess 

func (p *BeeswaxServiceGetDefaultConfigurationResult) GetSuccess() []*ConfigVariable

func (*BeeswaxServiceGetDefaultConfigurationResult) IsSetSuccess 

func (p *BeeswaxServiceGetDefaultConfigurationResult) IsSetSuccess() bool

func (*BeeswaxServiceGetDefaultConfigurationResult) Read 

func (p *BeeswaxServiceGetDefaultConfigurationResult) Read(iprot thrift.TProtocol) error

func (*BeeswaxServiceGetDefaultConfigurationResult) ReadField0 

func (p *BeeswaxServiceGetDefaultConfigurationResult) ReadField0(iprot thrift.TProtocol) error

func (*BeeswaxServiceGetDefaultConfigurationResult) String 

func (p *BeeswaxServiceGetDefaultConfigurationResult) String() string

func (*BeeswaxServiceGetDefaultConfigurationResult) Write 

func (p *BeeswaxServiceGetDefaultConfigurationResult) Write(oprot thrift.TProtocol) error

type BeeswaxServiceGetLogArgs 

type BeeswaxServiceGetLogArgs struct {
	Context LogContextId `thrift:"context,1" db:"context" json:"context"`
}

Attributes:

  • Context

func NewBeeswaxServiceGetLogArgs 

func NewBeeswaxServiceGetLogArgs() *BeeswaxServiceGetLogArgs

func (*BeeswaxServiceGetLogArgs) GetContext 

func (p *BeeswaxServiceGetLogArgs) GetContext() LogContextId

func (*BeeswaxServiceGetLogArgs) Read 

func (p *BeeswaxServiceGetLogArgs) Read(iprot thrift.TProtocol) error

func (*BeeswaxServiceGetLogArgs) ReadField1 

func (p *BeeswaxServiceGetLogArgs) ReadField1(iprot thrift.TProtocol) error

func (*BeeswaxServiceGetLogArgs) String 

func (p *BeeswaxServiceGetLogArgs) String() string

func (*BeeswaxServiceGetLogArgs) Write 

func (p *BeeswaxServiceGetLogArgs) Write(oprot thrift.TProtocol) error

type BeeswaxServiceGetLogResult 

type BeeswaxServiceGetLogResult struct {
	Success *string                 `thrift:"success,0" db:"success" json:"success,omitempty"`
	Error   *QueryNotFoundException `thrift:"error,1" db:"error" json:"error,omitempty"`
}

Attributes:

  • Success
  • Error

func NewBeeswaxServiceGetLogResult 

func NewBeeswaxServiceGetLogResult() *BeeswaxServiceGetLogResult

func (*BeeswaxServiceGetLogResult) GetError 

func (p *BeeswaxServiceGetLogResult) GetError() *QueryNotFoundException

func (*BeeswaxServiceGetLogResult) GetSuccess 

func (p *BeeswaxServiceGetLogResult) GetSuccess() string

func (*BeeswaxServiceGetLogResult) IsSetError 

func (p *BeeswaxServiceGetLogResult) IsSetError() bool

func (*BeeswaxServiceGetLogResult) IsSetSuccess 

func (p *BeeswaxServiceGetLogResult) IsSetSuccess() bool

func (*BeeswaxServiceGetLogResult) Read 

func (p *BeeswaxServiceGetLogResult) Read(iprot thrift.TProtocol) error

func (*BeeswaxServiceGetLogResult) ReadField0 

func (p *BeeswaxServiceGetLogResult) ReadField0(iprot thrift.TProtocol) error

func (*BeeswaxServiceGetLogResult) ReadField1 

func (p *BeeswaxServiceGetLogResult) ReadField1(iprot thrift.TProtocol) error

func (*BeeswaxServiceGetLogResult) String 

func (p *BeeswaxServiceGetLogResult) String() string

func (*BeeswaxServiceGetLogResult) Write 

func (p *BeeswaxServiceGetLogResult) Write(oprot thrift.TProtocol) error

type BeeswaxServiceGetResultsMetadataArgs 

type BeeswaxServiceGetResultsMetadataArgs struct {
	Handle *QueryHandle `thrift:"handle,1" db:"handle" json:"handle"`
}

Attributes:

  • Handle

func NewBeeswaxServiceGetResultsMetadataArgs 

func NewBeeswaxServiceGetResultsMetadataArgs() *BeeswaxServiceGetResultsMetadataArgs

func (*BeeswaxServiceGetResultsMetadataArgs) GetHandle 

func (p *BeeswaxServiceGetResultsMetadataArgs) GetHandle() *QueryHandle

func (*BeeswaxServiceGetResultsMetadataArgs) IsSetHandle 

func (p *BeeswaxServiceGetResultsMetadataArgs) IsSetHandle() bool

func (*BeeswaxServiceGetResultsMetadataArgs) Read 

func (p *BeeswaxServiceGetResultsMetadataArgs) Read(iprot thrift.TProtocol) error

func (*BeeswaxServiceGetResultsMetadataArgs) ReadField1 

func (p *BeeswaxServiceGetResultsMetadataArgs) ReadField1(iprot thrift.TProtocol) error

func (*BeeswaxServiceGetResultsMetadataArgs) String 

func (p *BeeswaxServiceGetResultsMetadataArgs) String() string

func (*BeeswaxServiceGetResultsMetadataArgs) Write 

func (p *BeeswaxServiceGetResultsMetadataArgs) Write(oprot thrift.TProtocol) error

type BeeswaxServiceGetResultsMetadataResult 

type BeeswaxServiceGetResultsMetadataResult struct {
	Success *ResultsMetadata        `thrift:"success,0" db:"success" json:"success,omitempty"`
	Error   *QueryNotFoundException `thrift:"error,1" db:"error" json:"error,omitempty"`
}

Attributes:

  • Success
  • Error

func NewBeeswaxServiceGetResultsMetadataResult 

func NewBeeswaxServiceGetResultsMetadataResult() *BeeswaxServiceGetResultsMetadataResult

func (*BeeswaxServiceGetResultsMetadataResult) GetError 

func (p *BeeswaxServiceGetResultsMetadataResult) GetError() *QueryNotFoundException

func (*BeeswaxServiceGetResultsMetadataResult) GetSuccess 

func (p *BeeswaxServiceGetResultsMetadataResult) GetSuccess() *ResultsMetadata

func (*BeeswaxServiceGetResultsMetadataResult) IsSetError 

func (p *BeeswaxServiceGetResultsMetadataResult) IsSetError() bool

func (*BeeswaxServiceGetResultsMetadataResult) IsSetSuccess 

func (p *BeeswaxServiceGetResultsMetadataResult) IsSetSuccess() bool

func (*BeeswaxServiceGetResultsMetadataResult) Read 

func (p *BeeswaxServiceGetResultsMetadataResult) Read(iprot thrift.TProtocol) error

func (*BeeswaxServiceGetResultsMetadataResult) ReadField0 

func (p *BeeswaxServiceGetResultsMetadataResult) ReadField0(iprot thrift.TProtocol) error

func (*BeeswaxServiceGetResultsMetadataResult) ReadField1 

func (p *BeeswaxServiceGetResultsMetadataResult) ReadField1(iprot thrift.TProtocol) error

func (*BeeswaxServiceGetResultsMetadataResult) String 

func (p *BeeswaxServiceGetResultsMetadataResult) String() string

func (*BeeswaxServiceGetResultsMetadataResult) Write 

func (p *BeeswaxServiceGetResultsMetadataResult) Write(oprot thrift.TProtocol) error

type BeeswaxServiceGetStateArgs 

type BeeswaxServiceGetStateArgs struct {
	Handle *QueryHandle `thrift:"handle,1" db:"handle" json:"handle"`
}

Attributes:

  • Handle

func NewBeeswaxServiceGetStateArgs 

func NewBeeswaxServiceGetStateArgs() *BeeswaxServiceGetStateArgs

func (*BeeswaxServiceGetStateArgs) GetHandle 

func (p *BeeswaxServiceGetStateArgs) GetHandle() *QueryHandle

func (*BeeswaxServiceGetStateArgs) IsSetHandle 

func (p *BeeswaxServiceGetStateArgs) IsSetHandle() bool

func (*BeeswaxServiceGetStateArgs) Read 

func (p *BeeswaxServiceGetStateArgs) Read(iprot thrift.TProtocol) error

func (*BeeswaxServiceGetStateArgs) ReadField1 

func (p *BeeswaxServiceGetStateArgs) ReadField1(iprot thrift.TProtocol) error

func (*BeeswaxServiceGetStateArgs) String 

func (p *BeeswaxServiceGetStateArgs) String() string

func (*BeeswaxServiceGetStateArgs) Write 

func (p *BeeswaxServiceGetStateArgs) Write(oprot thrift.TProtocol) error

type BeeswaxServiceGetStateResult 

type BeeswaxServiceGetStateResult struct {
	Success *QueryState             `thrift:"success,0" db:"success" json:"success,omitempty"`
	Error   *QueryNotFoundException `thrift:"error,1" db:"error" json:"error,omitempty"`
}

Attributes:

  • Success
  • Error

func NewBeeswaxServiceGetStateResult 

func NewBeeswaxServiceGetStateResult() *BeeswaxServiceGetStateResult

func (*BeeswaxServiceGetStateResult) GetError 

func (p *BeeswaxServiceGetStateResult) GetError() *QueryNotFoundException

func (*BeeswaxServiceGetStateResult) GetSuccess 

func (p *BeeswaxServiceGetStateResult) GetSuccess() QueryState

func (*BeeswaxServiceGetStateResult) IsSetError 

func (p *BeeswaxServiceGetStateResult) IsSetError() bool

func (*BeeswaxServiceGetStateResult) IsSetSuccess 

func (p *BeeswaxServiceGetStateResult) IsSetSuccess() bool

func (*BeeswaxServiceGetStateResult) Read 

func (p *BeeswaxServiceGetStateResult) Read(iprot thrift.TProtocol) error

func (*BeeswaxServiceGetStateResult) ReadField0 

func (p *BeeswaxServiceGetStateResult) ReadField0(iprot thrift.TProtocol) error

func (*BeeswaxServiceGetStateResult) ReadField1 

func (p *BeeswaxServiceGetStateResult) ReadField1(iprot thrift.TProtocol) error

func (*BeeswaxServiceGetStateResult) String 

func (p *BeeswaxServiceGetStateResult) String() string

func (*BeeswaxServiceGetStateResult) Write 

func (p *BeeswaxServiceGetStateResult) Write(oprot thrift.TProtocol) error

type BeeswaxServiceProcessor 

type BeeswaxServiceProcessor struct {
	// contains filtered or unexported fields
}

func NewBeeswaxServiceProcessor 

func NewBeeswaxServiceProcessor(handler BeeswaxService) *BeeswaxServiceProcessor

func (*BeeswaxServiceProcessor) AddToProcessorMap 

func (p *BeeswaxServiceProcessor) AddToProcessorMap(key string, processor thrift.TProcessorFunction)

func (*BeeswaxServiceProcessor) GetProcessorFunction 

func (p *BeeswaxServiceProcessor) GetProcessorFunction(key string) (processor thrift.TProcessorFunction, ok bool)

func (*BeeswaxServiceProcessor) Process 

func (p *BeeswaxServiceProcessor) Process(ctx context.Context, iprot, oprot thrift.TProtocol) (success bool, err thrift.TException)

func (*BeeswaxServiceProcessor) ProcessorMap 

func (p *BeeswaxServiceProcessor) ProcessorMap() map[string]thrift.TProcessorFunction

type BeeswaxServiceQueryArgs 

type BeeswaxServiceQueryArgs struct {
	Query *Query `thrift:"query,1" db:"query" json:"query"`
}

Attributes:

  • Query

func NewBeeswaxServiceQueryArgs 

func NewBeeswaxServiceQueryArgs() *BeeswaxServiceQueryArgs

func (*BeeswaxServiceQueryArgs) GetQuery 

func (p *BeeswaxServiceQueryArgs) GetQuery() *Query

func (*BeeswaxServiceQueryArgs) IsSetQuery 

func (p *BeeswaxServiceQueryArgs) IsSetQuery() bool

func (*BeeswaxServiceQueryArgs) Read 

func (p *BeeswaxServiceQueryArgs) Read(iprot thrift.TProtocol) error

func (*BeeswaxServiceQueryArgs) ReadField1 

func (p *BeeswaxServiceQueryArgs) ReadField1(iprot thrift.TProtocol) error

func (*BeeswaxServiceQueryArgs) String 

func (p *BeeswaxServiceQueryArgs) String() string

func (*BeeswaxServiceQueryArgs) Write 

func (p *BeeswaxServiceQueryArgs) Write(oprot thrift.TProtocol) error

type BeeswaxServiceQueryResult 

type BeeswaxServiceQueryResult struct {
	Success *QueryHandle      `thrift:"success,0" db:"success" json:"success,omitempty"`
	Error   *BeeswaxException `thrift:"error,1" db:"error" json:"error,omitempty"`
}

Attributes:

  • Success
  • Error

func NewBeeswaxServiceQueryResult 

func NewBeeswaxServiceQueryResult() *BeeswaxServiceQueryResult

func (*BeeswaxServiceQueryResult) GetError 

func (p *BeeswaxServiceQueryResult) GetError() *BeeswaxException

func (*BeeswaxServiceQueryResult) GetSuccess 

func (p *BeeswaxServiceQueryResult) GetSuccess() *QueryHandle

func (*BeeswaxServiceQueryResult) IsSetError 

func (p *BeeswaxServiceQueryResult) IsSetError() bool

func (*BeeswaxServiceQueryResult) IsSetSuccess 

func (p *BeeswaxServiceQueryResult) IsSetSuccess() bool

func (*BeeswaxServiceQueryResult) Read 

func (p *BeeswaxServiceQueryResult) Read(iprot thrift.TProtocol) error

func (*BeeswaxServiceQueryResult) ReadField0 

func (p *BeeswaxServiceQueryResult) ReadField0(iprot thrift.TProtocol) error

func (*BeeswaxServiceQueryResult) ReadField1 

func (p *BeeswaxServiceQueryResult) ReadField1(iprot thrift.TProtocol) error

func (*BeeswaxServiceQueryResult) String 

func (p *BeeswaxServiceQueryResult) String() string

func (*BeeswaxServiceQueryResult) Write 

func (p *BeeswaxServiceQueryResult) Write(oprot thrift.TProtocol) error

type ConfigVariable 

type ConfigVariable struct {
	Key         string `thrift:"key,1" db:"key" json:"key"`
	Value       string `thrift:"value,2" db:"value" json:"value"`
	Description string `thrift:"description,3" db:"description" json:"description"`
}

Represents a Hadoop-style configuration variable.

Attributes:

  • Key
  • Value
  • Description

func NewConfigVariable 

func NewConfigVariable() *ConfigVariable

func (*ConfigVariable) GetDescription 

func (p *ConfigVariable) GetDescription() string

func (*ConfigVariable) GetKey 

func (p *ConfigVariable) GetKey() string

func (*ConfigVariable) GetValue 

func (p *ConfigVariable) GetValue() string

func (*ConfigVariable) Read 

func (p *ConfigVariable) Read(iprot thrift.TProtocol) error

func (*ConfigVariable) ReadField1 

func (p *ConfigVariable) ReadField1(iprot thrift.TProtocol) error

func (*ConfigVariable) ReadField2 

func (p *ConfigVariable) ReadField2(iprot thrift.TProtocol) error

func (*ConfigVariable) ReadField3 

func (p *ConfigVariable) ReadField3(iprot thrift.TProtocol) error

func (*ConfigVariable) String 

func (p *ConfigVariable) String() string

func (*ConfigVariable) Write 

func (p *ConfigVariable) Write(oprot thrift.TProtocol) error

type LogContextId 

type LogContextId string

func LogContextIdPtr 

func LogContextIdPtr(v LogContextId) *LogContextId

type Query 

type Query struct {
	Query string `thrift:"query,1" db:"query" json:"query"`
	// unused field # 2
	Configuration []string `thrift:"configuration,3" db:"configuration" json:"configuration"`
	HadoopUser    string   `thrift:"hadoop_user,4" db:"hadoop_user" json:"hadoop_user"`
}

Attributes:

  • Query
  • Configuration
  • HadoopUser
var BeeswaxServiceExecuteAndWaitArgs_Query_DEFAULT *Query
var BeeswaxServiceExplainArgs_Query_DEFAULT *Query
var BeeswaxServiceQueryArgs_Query_DEFAULT *Query

func NewQuery 

func NewQuery() *Query

func (*Query) GetConfiguration 

func (p *Query) GetConfiguration() []string

func (*Query) GetHadoopUser 

func (p *Query) GetHadoopUser() string

func (*Query) GetQuery 

func (p *Query) GetQuery() string

func (*Query) Read 

func (p *Query) Read(iprot thrift.TProtocol) error

func (*Query) ReadField1 

func (p *Query) ReadField1(iprot thrift.TProtocol) error

func (*Query) ReadField3 

func (p *Query) ReadField3(iprot thrift.TProtocol) error

func (*Query) ReadField4 

func (p *Query) ReadField4(iprot thrift.TProtocol) error

func (*Query) String 

func (p *Query) String() string

func (*Query) Write 

func (p *Query) Write(oprot thrift.TProtocol) error

type QueryExplanation 

type QueryExplanation struct {
	Textual string `thrift:"textual,1" db:"textual" json:"textual"`
}

Attributes:

  • Textual
var BeeswaxServiceExplainResult_Success_DEFAULT *QueryExplanation

func NewQueryExplanation 

func NewQueryExplanation() *QueryExplanation

func (*QueryExplanation) GetTextual 

func (p *QueryExplanation) GetTextual() string

func (*QueryExplanation) Read 

func (p *QueryExplanation) Read(iprot thrift.TProtocol) error

func (*QueryExplanation) ReadField1 

func (p *QueryExplanation) ReadField1(iprot thrift.TProtocol) error

func (*QueryExplanation) String 

func (p *QueryExplanation) String() string

func (*QueryExplanation) Write 

func (p *QueryExplanation) Write(oprot thrift.TProtocol) error

type QueryHandle 

type QueryHandle struct {
	ID         string       `thrift:"id,1" db:"id" json:"id"`
	LogContext LogContextId `thrift:"log_context,2" db:"log_context" json:"log_context"`
}

Attributes:

  • ID
  • LogContext
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 

func NewQueryHandle() *QueryHandle

func (*QueryHandle) GetID 

func (p *QueryHandle) GetID() string

func (*QueryHandle) GetLogContext 

func (p *QueryHandle) GetLogContext() LogContextId

func (*QueryHandle) Read 

func (p *QueryHandle) Read(iprot thrift.TProtocol) error

func (*QueryHandle) ReadField1 

func (p *QueryHandle) ReadField1(iprot thrift.TProtocol) error

func (*QueryHandle) ReadField2 

func (p *QueryHandle) ReadField2(iprot thrift.TProtocol) error

func (*QueryHandle) String 

func (p *QueryHandle) String() string

func (*QueryHandle) Write 

func (p *QueryHandle) Write(oprot thrift.TProtocol) error

type QueryNotFoundException 

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 

func NewQueryNotFoundException() *QueryNotFoundException

func (*QueryNotFoundException) Error 

func (p *QueryNotFoundException) Error() string

func (*QueryNotFoundException) Read 

func (p *QueryNotFoundException) Read(iprot thrift.TProtocol) error

func (*QueryNotFoundException) String 

func (p *QueryNotFoundException) String() string

func (*QueryNotFoundException) Write 

func (p *QueryNotFoundException) Write(oprot thrift.TProtocol) error

type QueryState 

type QueryState int64
const (
	QueryState_CREATED     QueryState = 0
	QueryState_INITIALIZED QueryState = 1
	QueryState_COMPILED    QueryState = 2
	QueryState_RUNNING     QueryState = 3
	QueryState_FINISHED    QueryState = 4
	QueryState_EXCEPTION   QueryState = 5
)
var BeeswaxServiceGetStateResult_Success_DEFAULT QueryState

func QueryStateFromString 

func QueryStateFromString(s string) (QueryState, error)

func QueryStatePtr 

func QueryStatePtr(v QueryState) *QueryState

func (QueryState) MarshalText 

func (p QueryState) MarshalText() ([]byte, error)

func (*QueryState) Scan 

func (p *QueryState) Scan(value interface{}) error

func (QueryState) String 

func (p QueryState) String() string

func (*QueryState) UnmarshalText 

func (p *QueryState) UnmarshalText(text []byte) error

func (*QueryState) Value 

func (p *QueryState) Value() (driver.Value, error)

type Results 

type Results struct {
	Ready    bool     `thrift:"ready,1" db:"ready" json:"ready"`
	Columns  []string `thrift:"columns,2" db:"columns" json:"columns"`
	Data     []string `thrift:"data,3" db:"data" json:"data"`
	StartRow int64    `thrift:"start_row,4" db:"start_row" json:"start_row"`
	HasMore  bool     `thrift:"has_more,5" db:"has_more" json:"has_more"`
}

Attributes:

  • Ready
  • Columns
  • Data
  • StartRow
  • HasMore
var BeeswaxServiceFetchResult_Success_DEFAULT *Results

func NewResults 

func NewResults() *Results

func (*Results) GetColumns 

func (p *Results) GetColumns() []string

func (*Results) GetData 

func (p *Results) GetData() []string

func (*Results) GetHasMore 

func (p *Results) GetHasMore() bool

func (*Results) GetReady 

func (p *Results) GetReady() bool

func (*Results) GetStartRow 

func (p *Results) GetStartRow() int64

func (*Results) Read 

func (p *Results) Read(iprot thrift.TProtocol) error

func (*Results) ReadField1 

func (p *Results) ReadField1(iprot thrift.TProtocol) error

func (*Results) ReadField2 

func (p *Results) ReadField2(iprot thrift.TProtocol) error

func (*Results) ReadField3 

func (p *Results) ReadField3(iprot thrift.TProtocol) error

func (*Results) ReadField4 

func (p *Results) ReadField4(iprot thrift.TProtocol) error

func (*Results) ReadField5 

func (p *Results) ReadField5(iprot thrift.TProtocol) error

func (*Results) String 

func (p *Results) String() string

func (*Results) Write 

func (p *Results) Write(oprot thrift.TProtocol) error

type ResultsMetadata 

type ResultsMetadata struct {
	Schema      *hive_metastore.Schema `thrift:"schema,1" db:"schema" json:"schema"`
	TableDir    string                 `thrift:"table_dir,2" db:"table_dir" json:"table_dir"`
	InTablename string                 `thrift:"in_tablename,3" db:"in_tablename" json:"in_tablename"`
	Delim       string                 `thrift:"delim,4" db:"delim" json:"delim"`
}

Metadata information about the results. Applicable only for SELECT.

Attributes:

  • Schema: The schema of the results
  • TableDir: The directory containing the results. Not applicable for partition table.
  • InTablename: If the results are straight from an existing table, the table name.
  • Delim: Field delimiter
var BeeswaxServiceGetResultsMetadataResult_Success_DEFAULT *ResultsMetadata

func NewResultsMetadata 

func NewResultsMetadata() *ResultsMetadata

func (*ResultsMetadata) GetDelim 

func (p *ResultsMetadata) GetDelim() string

func (*ResultsMetadata) GetInTablename 

func (p *ResultsMetadata) GetInTablename() string

func (*ResultsMetadata) GetSchema 

func (p *ResultsMetadata) GetSchema() *hive_metastore.Schema

func (*ResultsMetadata) GetTableDir 

func (p *ResultsMetadata) GetTableDir() string

func (*ResultsMetadata) IsSetSchema 

func (p *ResultsMetadata) IsSetSchema() bool

func (*ResultsMetadata) Read 

func (p *ResultsMetadata) Read(iprot thrift.TProtocol) error

func (*ResultsMetadata) ReadField1 

func (p *ResultsMetadata) ReadField1(iprot thrift.TProtocol) error

func (*ResultsMetadata) ReadField2 

func (p *ResultsMetadata) ReadField2(iprot thrift.TProtocol) error

func (*ResultsMetadata) ReadField3 

func (p *ResultsMetadata) ReadField3(iprot thrift.TProtocol) error

func (*ResultsMetadata) ReadField4 

func (p *ResultsMetadata) ReadField4(iprot thrift.TProtocol) error

func (*ResultsMetadata) String 

func (p *ResultsMetadata) String() string

func (*ResultsMetadata) Write 

func (p *ResultsMetadata) Write(oprot thrift.TProtocol) error

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.