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 (*BeeswaxServiceCleanArgs) ReadField1

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

func (*BeeswaxServiceCleanArgs) String

func (p *BeeswaxServiceCleanArgs) String() string

func (*BeeswaxServiceCleanArgs) Write

type BeeswaxServiceCleanResult

type BeeswaxServiceCleanResult struct {
}

func NewBeeswaxServiceCleanResult

func NewBeeswaxServiceCleanResult() *BeeswaxServiceCleanResult

func (*BeeswaxServiceCleanResult) Read

func (*BeeswaxServiceCleanResult) String

func (p *BeeswaxServiceCleanResult) String() string

func (*BeeswaxServiceCleanResult) Write

type BeeswaxServiceClient

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

func NewBeeswaxServiceClient

func NewBeeswaxServiceClient(c thrift.TClient) *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 (*BeeswaxServiceCloseArgs) ReadField1

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

func (*BeeswaxServiceCloseArgs) String

func (p *BeeswaxServiceCloseArgs) String() string

func (*BeeswaxServiceCloseArgs) Write

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 (*BeeswaxServiceCloseResult) GetError2

func (*BeeswaxServiceCloseResult) IsSetError

func (p *BeeswaxServiceCloseResult) IsSetError() bool

func (*BeeswaxServiceCloseResult) IsSetError2

func (p *BeeswaxServiceCloseResult) IsSetError2() bool

func (*BeeswaxServiceCloseResult) Read

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

type BeeswaxServiceDumpConfigArgs

type BeeswaxServiceDumpConfigArgs struct {
}

func NewBeeswaxServiceDumpConfigArgs

func NewBeeswaxServiceDumpConfigArgs() *BeeswaxServiceDumpConfigArgs

func (*BeeswaxServiceDumpConfigArgs) Read

func (*BeeswaxServiceDumpConfigArgs) String

func (*BeeswaxServiceDumpConfigArgs) Write

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 (*BeeswaxServiceDumpConfigResult) ReadField0

func (*BeeswaxServiceDumpConfigResult) String

func (*BeeswaxServiceDumpConfigResult) Write

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 (*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 (*BeeswaxServiceEchoResult) ReadField0

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

func (*BeeswaxServiceEchoResult) String

func (p *BeeswaxServiceEchoResult) String() string

func (*BeeswaxServiceEchoResult) Write

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 (*BeeswaxServiceExecuteAndWaitArgs) GetQuery

func (p *BeeswaxServiceExecuteAndWaitArgs) GetQuery() *Query

func (*BeeswaxServiceExecuteAndWaitArgs) IsSetQuery

func (p *BeeswaxServiceExecuteAndWaitArgs) IsSetQuery() bool

func (*BeeswaxServiceExecuteAndWaitArgs) Read

func (*BeeswaxServiceExecuteAndWaitArgs) ReadField1

func (*BeeswaxServiceExecuteAndWaitArgs) ReadField2

func (*BeeswaxServiceExecuteAndWaitArgs) String

func (*BeeswaxServiceExecuteAndWaitArgs) Write

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 (*BeeswaxServiceExecuteAndWaitResult) GetSuccess

func (*BeeswaxServiceExecuteAndWaitResult) IsSetError

func (p *BeeswaxServiceExecuteAndWaitResult) IsSetError() bool

func (*BeeswaxServiceExecuteAndWaitResult) IsSetSuccess

func (p *BeeswaxServiceExecuteAndWaitResult) IsSetSuccess() bool

func (*BeeswaxServiceExecuteAndWaitResult) Read

func (*BeeswaxServiceExecuteAndWaitResult) ReadField0

func (*BeeswaxServiceExecuteAndWaitResult) ReadField1

func (*BeeswaxServiceExecuteAndWaitResult) String

func (*BeeswaxServiceExecuteAndWaitResult) Write

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 (*BeeswaxServiceExplainArgs) ReadField1

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

func (*BeeswaxServiceExplainArgs) String

func (p *BeeswaxServiceExplainArgs) String() string

func (*BeeswaxServiceExplainArgs) Write

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 (*BeeswaxServiceExplainResult) GetSuccess

func (*BeeswaxServiceExplainResult) IsSetError

func (p *BeeswaxServiceExplainResult) IsSetError() bool

func (*BeeswaxServiceExplainResult) IsSetSuccess

func (p *BeeswaxServiceExplainResult) IsSetSuccess() bool

func (*BeeswaxServiceExplainResult) Read

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

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 (*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

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 (*BeeswaxServiceFetchResult) GetError2

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 (*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

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 (*BeeswaxServiceGetDefaultConfigurationArgs) ReadField1

func (*BeeswaxServiceGetDefaultConfigurationArgs) String

func (*BeeswaxServiceGetDefaultConfigurationArgs) Write

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 (*BeeswaxServiceGetDefaultConfigurationResult) IsSetSuccess

func (*BeeswaxServiceGetDefaultConfigurationResult) Read

func (*BeeswaxServiceGetDefaultConfigurationResult) ReadField0

func (*BeeswaxServiceGetDefaultConfigurationResult) String

func (*BeeswaxServiceGetDefaultConfigurationResult) Write

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 (*BeeswaxServiceGetLogArgs) ReadField1

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

func (*BeeswaxServiceGetLogArgs) String

func (p *BeeswaxServiceGetLogArgs) String() string

func (*BeeswaxServiceGetLogArgs) Write

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 (*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 (*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

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 (*BeeswaxServiceGetResultsMetadataArgs) IsSetHandle

func (p *BeeswaxServiceGetResultsMetadataArgs) IsSetHandle() bool

func (*BeeswaxServiceGetResultsMetadataArgs) Read

func (*BeeswaxServiceGetResultsMetadataArgs) ReadField1

func (*BeeswaxServiceGetResultsMetadataArgs) String

func (*BeeswaxServiceGetResultsMetadataArgs) Write

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 (*BeeswaxServiceGetResultsMetadataResult) GetSuccess

func (*BeeswaxServiceGetResultsMetadataResult) IsSetError

func (*BeeswaxServiceGetResultsMetadataResult) IsSetSuccess

func (p *BeeswaxServiceGetResultsMetadataResult) IsSetSuccess() bool

func (*BeeswaxServiceGetResultsMetadataResult) Read

func (*BeeswaxServiceGetResultsMetadataResult) ReadField0

func (*BeeswaxServiceGetResultsMetadataResult) ReadField1

func (*BeeswaxServiceGetResultsMetadataResult) String

func (*BeeswaxServiceGetResultsMetadataResult) Write

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 (*BeeswaxServiceGetStateArgs) ReadField1

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

func (*BeeswaxServiceGetStateArgs) String

func (p *BeeswaxServiceGetStateArgs) String() string

func (*BeeswaxServiceGetStateArgs) Write

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 (*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 (*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 (*BeeswaxServiceGetStateResult) Write

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

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 (*BeeswaxServiceQueryArgs) ReadField1

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

func (*BeeswaxServiceQueryArgs) String

func (p *BeeswaxServiceQueryArgs) String() string

func (*BeeswaxServiceQueryArgs) Write

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 (*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 (*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

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 (*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

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL