impalaservice

package
v1.4.1 Latest Latest
Warning

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

 Go to latest Published: Dec 23, 2025 License: MIT Imports: 12 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var GoUnusedProtection__ int
View Source 
var TCloseImpalaOperationReq_OperationHandle_DEFAULT *cli_service.TOperationHandle
View Source 
var TCloseImpalaOperationResp_Status_DEFAULT *cli_service.TStatus
View Source 
var TDmlResult__NumRowErrors_DEFAULT int64
View Source 
var TDmlResult__RowsDeleted_DEFAULT map[string]int64
View Source 
var TGetExecSummaryReq_IncludeQueryAttempts_DEFAULT bool = false
View Source 
var TGetExecSummaryReq_OperationHandle_DEFAULT *cli_service.TOperationHandle
View Source 
var TGetExecSummaryReq_SessionHandle_DEFAULT *cli_service.TSessionHandle
View Source 
var TGetExecSummaryResp_FailedSummaries_DEFAULT []*execstats.TExecSummary
View Source 
var TGetExecSummaryResp_Status_DEFAULT *cli_service.TStatus
View Source 
var TGetExecSummaryResp_Summary_DEFAULT *execstats.TExecSummary
View Source 
var TPingImpalaHS2ServiceReq_SessionHandle_DEFAULT *cli_service.TSessionHandle
View Source 
var TPingImpalaHS2ServiceResp_Status_DEFAULT *cli_service.TStatus
View Source 
var TPingImpalaHS2ServiceResp_Timestamp_DEFAULT int64
View Source 
var TPingImpalaHS2ServiceResp_Version_DEFAULT string
View Source 
var TPingImpalaHS2ServiceResp_WebserverAddress_DEFAULT string

Functions

This section is empty.

Types

type ImpalaHiveServer2Service 

type ImpalaHiveServer2Service interface {
	cli_service.TCLIService

	// Parameters:
	//  - Req
	//
	GetExecSummary(ctx context.Context, req *TGetExecSummaryReq) (_r *TGetExecSummaryResp, _err error)
	// Parameters:
	//  - Req
	//
	PingImpalaHS2Service(ctx context.Context, req *TPingImpalaHS2ServiceReq) (_r *TPingImpalaHS2ServiceResp, _err error)
	// Parameters:
	//  - Req
	//
	CloseImpalaOperation(ctx context.Context, req *TCloseImpalaOperationReq) (_r *TCloseImpalaOperationResp, _err error)
}

type ImpalaHiveServer2ServiceClient 

type ImpalaHiveServer2ServiceClient struct {
	*cli_service.TCLIServiceClient
}

func NewImpalaHiveServer2ServiceClient 

func NewImpalaHiveServer2ServiceClient(c thrift.TClient) *ImpalaHiveServer2ServiceClient

func NewImpalaHiveServer2ServiceClientFactory 

func NewImpalaHiveServer2ServiceClientFactory(t thrift.TTransport, f thrift.TProtocolFactory) *ImpalaHiveServer2ServiceClient

func NewImpalaHiveServer2ServiceClientProtocol 

func NewImpalaHiveServer2ServiceClientProtocol(t thrift.TTransport, iprot thrift.TProtocol, oprot thrift.TProtocol) *ImpalaHiveServer2ServiceClient

func (*ImpalaHiveServer2ServiceClient) CloseImpalaOperation added in v1.1.0 

func (p *ImpalaHiveServer2ServiceClient) CloseImpalaOperation(ctx context.Context, req *TCloseImpalaOperationReq) (_r *TCloseImpalaOperationResp, _err error)

Parameters:

  • Req

func (*ImpalaHiveServer2ServiceClient) GetExecSummary added in v1.1.0 

func (p *ImpalaHiveServer2ServiceClient) GetExecSummary(ctx context.Context, req *TGetExecSummaryReq) (_r *TGetExecSummaryResp, _err error)

Parameters:

  • Req

func (*ImpalaHiveServer2ServiceClient) PingImpalaHS2Service added in v1.1.0 

func (p *ImpalaHiveServer2ServiceClient) PingImpalaHS2Service(ctx context.Context, req *TPingImpalaHS2ServiceReq) (_r *TPingImpalaHS2ServiceResp, _err error)

Parameters:

  • Req

type ImpalaHiveServer2ServiceCloseImpalaOperationArgs added in v1.1.0 

type ImpalaHiveServer2ServiceCloseImpalaOperationArgs struct {
	Req *TCloseImpalaOperationReq `thrift:"req,1" db:"req" json:"req"`
}

Attributes:

  • Req

func NewImpalaHiveServer2ServiceCloseImpalaOperationArgs added in v1.1.0 

func NewImpalaHiveServer2ServiceCloseImpalaOperationArgs() *ImpalaHiveServer2ServiceCloseImpalaOperationArgs

func (*ImpalaHiveServer2ServiceCloseImpalaOperationArgs) GetReq added in v1.1.0 

func (p *ImpalaHiveServer2ServiceCloseImpalaOperationArgs) GetReq() *TCloseImpalaOperationReq

func (*ImpalaHiveServer2ServiceCloseImpalaOperationArgs) IsSetReq added in v1.1.0 

func (p *ImpalaHiveServer2ServiceCloseImpalaOperationArgs) IsSetReq() bool

func (*ImpalaHiveServer2ServiceCloseImpalaOperationArgs) LogValue added in v1.1.0 

func (p *ImpalaHiveServer2ServiceCloseImpalaOperationArgs) LogValue() slog.Value

func (*ImpalaHiveServer2ServiceCloseImpalaOperationArgs) Read added in v1.1.0 

func (p *ImpalaHiveServer2ServiceCloseImpalaOperationArgs) Read(ctx context.Context, iprot thrift.TProtocol) error

func (*ImpalaHiveServer2ServiceCloseImpalaOperationArgs) ReadField1 added in v1.1.0 

func (p *ImpalaHiveServer2ServiceCloseImpalaOperationArgs) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*ImpalaHiveServer2ServiceCloseImpalaOperationArgs) String added in v1.1.0 

func (p *ImpalaHiveServer2ServiceCloseImpalaOperationArgs) String() string

func (*ImpalaHiveServer2ServiceCloseImpalaOperationArgs) Write added in v1.1.0 

func (p *ImpalaHiveServer2ServiceCloseImpalaOperationArgs) Write(ctx context.Context, oprot thrift.TProtocol) error

type ImpalaHiveServer2ServiceCloseImpalaOperationResult added in v1.1.0 

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

Attributes:

  • Success

func NewImpalaHiveServer2ServiceCloseImpalaOperationResult added in v1.1.0 

func NewImpalaHiveServer2ServiceCloseImpalaOperationResult() *ImpalaHiveServer2ServiceCloseImpalaOperationResult

func (*ImpalaHiveServer2ServiceCloseImpalaOperationResult) GetSuccess added in v1.1.0 

func (p *ImpalaHiveServer2ServiceCloseImpalaOperationResult) GetSuccess() *TCloseImpalaOperationResp

func (*ImpalaHiveServer2ServiceCloseImpalaOperationResult) IsSetSuccess added in v1.1.0 

func (p *ImpalaHiveServer2ServiceCloseImpalaOperationResult) IsSetSuccess() bool

func (*ImpalaHiveServer2ServiceCloseImpalaOperationResult) LogValue added in v1.1.0 

func (p *ImpalaHiveServer2ServiceCloseImpalaOperationResult) LogValue() slog.Value

func (*ImpalaHiveServer2ServiceCloseImpalaOperationResult) Read added in v1.1.0 

func (p *ImpalaHiveServer2ServiceCloseImpalaOperationResult) Read(ctx context.Context, iprot thrift.TProtocol) error

func (*ImpalaHiveServer2ServiceCloseImpalaOperationResult) ReadField0 added in v1.1.0 

func (p *ImpalaHiveServer2ServiceCloseImpalaOperationResult) ReadField0(ctx context.Context, iprot thrift.TProtocol) error

func (*ImpalaHiveServer2ServiceCloseImpalaOperationResult) String added in v1.1.0 

func (p *ImpalaHiveServer2ServiceCloseImpalaOperationResult) String() string

func (*ImpalaHiveServer2ServiceCloseImpalaOperationResult) Write added in v1.1.0 

func (p *ImpalaHiveServer2ServiceCloseImpalaOperationResult) Write(ctx context.Context, oprot thrift.TProtocol) error

type ImpalaHiveServer2ServiceGetExecSummaryArgs added in v1.1.0 

type ImpalaHiveServer2ServiceGetExecSummaryArgs struct {
	Req *TGetExecSummaryReq `thrift:"req,1" db:"req" json:"req"`
}

Attributes:

  • Req

func NewImpalaHiveServer2ServiceGetExecSummaryArgs added in v1.1.0 

func NewImpalaHiveServer2ServiceGetExecSummaryArgs() *ImpalaHiveServer2ServiceGetExecSummaryArgs

func (*ImpalaHiveServer2ServiceGetExecSummaryArgs) GetReq added in v1.1.0 

func (p *ImpalaHiveServer2ServiceGetExecSummaryArgs) GetReq() *TGetExecSummaryReq

func (*ImpalaHiveServer2ServiceGetExecSummaryArgs) IsSetReq added in v1.1.0 

func (p *ImpalaHiveServer2ServiceGetExecSummaryArgs) IsSetReq() bool

func (*ImpalaHiveServer2ServiceGetExecSummaryArgs) LogValue added in v1.1.0 

func (p *ImpalaHiveServer2ServiceGetExecSummaryArgs) LogValue() slog.Value

func (*ImpalaHiveServer2ServiceGetExecSummaryArgs) Read added in v1.1.0 

func (p *ImpalaHiveServer2ServiceGetExecSummaryArgs) Read(ctx context.Context, iprot thrift.TProtocol) error

func (*ImpalaHiveServer2ServiceGetExecSummaryArgs) ReadField1 added in v1.1.0 

func (p *ImpalaHiveServer2ServiceGetExecSummaryArgs) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*ImpalaHiveServer2ServiceGetExecSummaryArgs) String added in v1.1.0 

func (p *ImpalaHiveServer2ServiceGetExecSummaryArgs) String() string

func (*ImpalaHiveServer2ServiceGetExecSummaryArgs) Write added in v1.1.0 

func (p *ImpalaHiveServer2ServiceGetExecSummaryArgs) Write(ctx context.Context, oprot thrift.TProtocol) error

type ImpalaHiveServer2ServiceGetExecSummaryResult added in v1.1.0 

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

Attributes:

  • Success

func NewImpalaHiveServer2ServiceGetExecSummaryResult added in v1.1.0 

func NewImpalaHiveServer2ServiceGetExecSummaryResult() *ImpalaHiveServer2ServiceGetExecSummaryResult

func (*ImpalaHiveServer2ServiceGetExecSummaryResult) GetSuccess added in v1.1.0 

func (p *ImpalaHiveServer2ServiceGetExecSummaryResult) GetSuccess() *TGetExecSummaryResp

func (*ImpalaHiveServer2ServiceGetExecSummaryResult) IsSetSuccess added in v1.1.0 

func (p *ImpalaHiveServer2ServiceGetExecSummaryResult) IsSetSuccess() bool

func (*ImpalaHiveServer2ServiceGetExecSummaryResult) LogValue added in v1.1.0 

func (p *ImpalaHiveServer2ServiceGetExecSummaryResult) LogValue() slog.Value

func (*ImpalaHiveServer2ServiceGetExecSummaryResult) Read added in v1.1.0 

func (p *ImpalaHiveServer2ServiceGetExecSummaryResult) Read(ctx context.Context, iprot thrift.TProtocol) error

func (*ImpalaHiveServer2ServiceGetExecSummaryResult) ReadField0 added in v1.1.0 

func (p *ImpalaHiveServer2ServiceGetExecSummaryResult) ReadField0(ctx context.Context, iprot thrift.TProtocol) error

func (*ImpalaHiveServer2ServiceGetExecSummaryResult) String added in v1.1.0 

func (p *ImpalaHiveServer2ServiceGetExecSummaryResult) String() string

func (*ImpalaHiveServer2ServiceGetExecSummaryResult) Write added in v1.1.0 

func (p *ImpalaHiveServer2ServiceGetExecSummaryResult) Write(ctx context.Context, oprot thrift.TProtocol) error

type ImpalaHiveServer2ServicePingImpalaHS2ServiceArgs added in v1.1.0 

type ImpalaHiveServer2ServicePingImpalaHS2ServiceArgs struct {
	Req *TPingImpalaHS2ServiceReq `thrift:"req,1" db:"req" json:"req"`
}

Attributes:

  • Req

func NewImpalaHiveServer2ServicePingImpalaHS2ServiceArgs added in v1.1.0 

func NewImpalaHiveServer2ServicePingImpalaHS2ServiceArgs() *ImpalaHiveServer2ServicePingImpalaHS2ServiceArgs

func (*ImpalaHiveServer2ServicePingImpalaHS2ServiceArgs) GetReq added in v1.1.0 

func (p *ImpalaHiveServer2ServicePingImpalaHS2ServiceArgs) GetReq() *TPingImpalaHS2ServiceReq

func (*ImpalaHiveServer2ServicePingImpalaHS2ServiceArgs) IsSetReq added in v1.1.0 

func (p *ImpalaHiveServer2ServicePingImpalaHS2ServiceArgs) IsSetReq() bool

func (*ImpalaHiveServer2ServicePingImpalaHS2ServiceArgs) LogValue added in v1.1.0 

func (p *ImpalaHiveServer2ServicePingImpalaHS2ServiceArgs) LogValue() slog.Value

func (*ImpalaHiveServer2ServicePingImpalaHS2ServiceArgs) Read added in v1.1.0 

func (p *ImpalaHiveServer2ServicePingImpalaHS2ServiceArgs) Read(ctx context.Context, iprot thrift.TProtocol) error

func (*ImpalaHiveServer2ServicePingImpalaHS2ServiceArgs) ReadField1 added in v1.1.0 

func (p *ImpalaHiveServer2ServicePingImpalaHS2ServiceArgs) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*ImpalaHiveServer2ServicePingImpalaHS2ServiceArgs) String added in v1.1.0 

func (p *ImpalaHiveServer2ServicePingImpalaHS2ServiceArgs) String() string

func (*ImpalaHiveServer2ServicePingImpalaHS2ServiceArgs) Write added in v1.1.0 

func (p *ImpalaHiveServer2ServicePingImpalaHS2ServiceArgs) Write(ctx context.Context, oprot thrift.TProtocol) error

type ImpalaHiveServer2ServicePingImpalaHS2ServiceResult added in v1.1.0 

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

Attributes:

  • Success

func NewImpalaHiveServer2ServicePingImpalaHS2ServiceResult added in v1.1.0 

func NewImpalaHiveServer2ServicePingImpalaHS2ServiceResult() *ImpalaHiveServer2ServicePingImpalaHS2ServiceResult

func (*ImpalaHiveServer2ServicePingImpalaHS2ServiceResult) GetSuccess added in v1.1.0 

func (p *ImpalaHiveServer2ServicePingImpalaHS2ServiceResult) GetSuccess() *TPingImpalaHS2ServiceResp

func (*ImpalaHiveServer2ServicePingImpalaHS2ServiceResult) IsSetSuccess added in v1.1.0 

func (p *ImpalaHiveServer2ServicePingImpalaHS2ServiceResult) IsSetSuccess() bool

func (*ImpalaHiveServer2ServicePingImpalaHS2ServiceResult) LogValue added in v1.1.0 

func (p *ImpalaHiveServer2ServicePingImpalaHS2ServiceResult) LogValue() slog.Value

func (*ImpalaHiveServer2ServicePingImpalaHS2ServiceResult) Read added in v1.1.0 

func (p *ImpalaHiveServer2ServicePingImpalaHS2ServiceResult) Read(ctx context.Context, iprot thrift.TProtocol) error

func (*ImpalaHiveServer2ServicePingImpalaHS2ServiceResult) ReadField0 added in v1.1.0 

func (p *ImpalaHiveServer2ServicePingImpalaHS2ServiceResult) ReadField0(ctx context.Context, iprot thrift.TProtocol) error

func (*ImpalaHiveServer2ServicePingImpalaHS2ServiceResult) String added in v1.1.0 

func (p *ImpalaHiveServer2ServicePingImpalaHS2ServiceResult) String() string

func (*ImpalaHiveServer2ServicePingImpalaHS2ServiceResult) Write added in v1.1.0 

func (p *ImpalaHiveServer2ServicePingImpalaHS2ServiceResult) Write(ctx context.Context, oprot thrift.TProtocol) error

type ImpalaHiveServer2ServiceProcessor 

type ImpalaHiveServer2ServiceProcessor struct {
	*cli_service.TCLIServiceProcessor
}

func NewImpalaHiveServer2ServiceProcessor 

func NewImpalaHiveServer2ServiceProcessor(handler ImpalaHiveServer2Service) *ImpalaHiveServer2ServiceProcessor

type TCloseImpalaOperationReq added in v1.1.0 

type TCloseImpalaOperationReq struct {
	OperationHandle *cli_service.TOperationHandle `thrift:"operationHandle,1,required" db:"operationHandle" json:"operationHandle"`
}

Attributes:

  • OperationHandle
var ImpalaHiveServer2ServiceCloseImpalaOperationArgs_Req_DEFAULT *TCloseImpalaOperationReq

func NewTCloseImpalaOperationReq added in v1.1.0 

func NewTCloseImpalaOperationReq() *TCloseImpalaOperationReq

func (*TCloseImpalaOperationReq) Equals added in v1.1.0 

func (p *TCloseImpalaOperationReq) Equals(other *TCloseImpalaOperationReq) bool

func (*TCloseImpalaOperationReq) GetOperationHandle added in v1.1.0 

func (p *TCloseImpalaOperationReq) GetOperationHandle() *cli_service.TOperationHandle

func (*TCloseImpalaOperationReq) IsSetOperationHandle added in v1.1.0 

func (p *TCloseImpalaOperationReq) IsSetOperationHandle() bool

func (*TCloseImpalaOperationReq) LogValue added in v1.1.0 

func (p *TCloseImpalaOperationReq) LogValue() slog.Value

func (*TCloseImpalaOperationReq) Read added in v1.1.0 

func (p *TCloseImpalaOperationReq) Read(ctx context.Context, iprot thrift.TProtocol) error

func (*TCloseImpalaOperationReq) ReadField1 added in v1.1.0 

func (p *TCloseImpalaOperationReq) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*TCloseImpalaOperationReq) String added in v1.1.0 

func (p *TCloseImpalaOperationReq) String() string

func (*TCloseImpalaOperationReq) Validate added in v1.1.0 

func (p *TCloseImpalaOperationReq) Validate() error

func (*TCloseImpalaOperationReq) Write added in v1.1.0 

func (p *TCloseImpalaOperationReq) Write(ctx context.Context, oprot thrift.TProtocol) error

type TCloseImpalaOperationResp added in v1.1.0 

type TCloseImpalaOperationResp struct {
	Status     *cli_service.TStatus `thrift:"status,1,required" db:"status" json:"status"`
	DmlResult_ *TDmlResult_         `thrift:"dml_result,2" db:"dml_result" json:"dml_result,omitempty"`
}

Attributes:

  • Status
  • DmlResult_
var ImpalaHiveServer2ServiceCloseImpalaOperationResult_Success_DEFAULT *TCloseImpalaOperationResp

func NewTCloseImpalaOperationResp added in v1.1.0 

func NewTCloseImpalaOperationResp() *TCloseImpalaOperationResp

func (*TCloseImpalaOperationResp) Equals added in v1.1.0 

func (p *TCloseImpalaOperationResp) Equals(other *TCloseImpalaOperationResp) bool

func (*TCloseImpalaOperationResp) GetDmlResult_ added in v1.1.0 

func (p *TCloseImpalaOperationResp) GetDmlResult_() *TDmlResult_

func (*TCloseImpalaOperationResp) GetStatus added in v1.1.0 

func (p *TCloseImpalaOperationResp) GetStatus() *cli_service.TStatus

func (*TCloseImpalaOperationResp) IsSetDmlResult_ added in v1.1.0 

func (p *TCloseImpalaOperationResp) IsSetDmlResult_() bool

func (*TCloseImpalaOperationResp) IsSetStatus added in v1.1.0 

func (p *TCloseImpalaOperationResp) IsSetStatus() bool

func (*TCloseImpalaOperationResp) LogValue added in v1.1.0 

func (p *TCloseImpalaOperationResp) LogValue() slog.Value

func (*TCloseImpalaOperationResp) Read added in v1.1.0 

func (p *TCloseImpalaOperationResp) Read(ctx context.Context, iprot thrift.TProtocol) error

func (*TCloseImpalaOperationResp) ReadField1 added in v1.1.0 

func (p *TCloseImpalaOperationResp) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*TCloseImpalaOperationResp) ReadField2 added in v1.1.0 

func (p *TCloseImpalaOperationResp) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

func (*TCloseImpalaOperationResp) String added in v1.1.0 

func (p *TCloseImpalaOperationResp) String() string

func (*TCloseImpalaOperationResp) Validate added in v1.1.0 

func (p *TCloseImpalaOperationResp) Validate() error

func (*TCloseImpalaOperationResp) Write added in v1.1.0 

func (p *TCloseImpalaOperationResp) Write(ctx context.Context, oprot thrift.TProtocol) error

type TDmlResult_ added in v1.1.0 

type TDmlResult_ struct {
	RowsModified map[string]int64 `thrift:"rows_modified,1,required" db:"rows_modified" json:"rows_modified"`
	NumRowErrors *int64           `thrift:"num_row_errors,2" db:"num_row_errors" json:"num_row_errors,omitempty"`
	RowsDeleted  map[string]int64 `thrift:"rows_deleted,3" db:"rows_deleted" json:"rows_deleted,omitempty"`
}

Attributes:

  • RowsModified
  • RowsDeleted
  • NumRowErrors
var TCloseImpalaOperationResp_DmlResult__DEFAULT *TDmlResult_

func NewTDmlResult_ added in v1.1.0 

func NewTDmlResult_() *TDmlResult_

func (*TDmlResult_) Equals added in v1.1.0 

func (p *TDmlResult_) Equals(other *TDmlResult_) bool

func (*TDmlResult_) GetNumRowErrors added in v1.1.0 

func (p *TDmlResult_) GetNumRowErrors() int64

func (*TDmlResult_) GetRowsDeleted added in v1.1.0 

func (p *TDmlResult_) GetRowsDeleted() map[string]int64

func (*TDmlResult_) GetRowsModified added in v1.1.0 

func (p *TDmlResult_) GetRowsModified() map[string]int64

func (*TDmlResult_) IsSetNumRowErrors added in v1.1.0 

func (p *TDmlResult_) IsSetNumRowErrors() bool

func (*TDmlResult_) IsSetRowsDeleted added in v1.1.0 

func (p *TDmlResult_) IsSetRowsDeleted() bool

func (*TDmlResult_) LogValue added in v1.1.0 

func (p *TDmlResult_) LogValue() slog.Value

func (*TDmlResult_) Read added in v1.1.0 

func (p *TDmlResult_) Read(ctx context.Context, iprot thrift.TProtocol) error

func (*TDmlResult_) ReadField1 added in v1.1.0 

func (p *TDmlResult_) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*TDmlResult_) ReadField2 added in v1.1.0 

func (p *TDmlResult_) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

func (*TDmlResult_) ReadField3 added in v1.1.0 

func (p *TDmlResult_) ReadField3(ctx context.Context, iprot thrift.TProtocol) error

func (*TDmlResult_) String added in v1.1.0 

func (p *TDmlResult_) String() string

func (*TDmlResult_) Validate added in v1.1.0 

func (p *TDmlResult_) Validate() error

func (*TDmlResult_) Write added in v1.1.0 

func (p *TDmlResult_) Write(ctx context.Context, oprot thrift.TProtocol) error

type TGetExecSummaryReq added in v1.1.0 

type TGetExecSummaryReq struct {
	OperationHandle      *cli_service.TOperationHandle `thrift:"operationHandle,1" db:"operationHandle" json:"operationHandle,omitempty"`
	SessionHandle        *cli_service.TSessionHandle   `thrift:"sessionHandle,2" db:"sessionHandle" json:"sessionHandle,omitempty"`
	IncludeQueryAttempts bool                          `thrift:"include_query_attempts,3" db:"include_query_attempts" json:"include_query_attempts"`
}

Attributes:

  • OperationHandle
  • SessionHandle
  • IncludeQueryAttempts
var ImpalaHiveServer2ServiceGetExecSummaryArgs_Req_DEFAULT *TGetExecSummaryReq

func NewTGetExecSummaryReq added in v1.1.0 

func NewTGetExecSummaryReq() *TGetExecSummaryReq

func (*TGetExecSummaryReq) Equals added in v1.1.0 

func (p *TGetExecSummaryReq) Equals(other *TGetExecSummaryReq) bool

func (*TGetExecSummaryReq) GetIncludeQueryAttempts added in v1.1.0 

func (p *TGetExecSummaryReq) GetIncludeQueryAttempts() bool

func (*TGetExecSummaryReq) GetOperationHandle added in v1.1.0 

func (p *TGetExecSummaryReq) GetOperationHandle() *cli_service.TOperationHandle

func (*TGetExecSummaryReq) GetSessionHandle added in v1.1.0 

func (p *TGetExecSummaryReq) GetSessionHandle() *cli_service.TSessionHandle

func (*TGetExecSummaryReq) IsSetIncludeQueryAttempts added in v1.1.0 

func (p *TGetExecSummaryReq) IsSetIncludeQueryAttempts() bool

func (*TGetExecSummaryReq) IsSetOperationHandle added in v1.1.0 

func (p *TGetExecSummaryReq) IsSetOperationHandle() bool

func (*TGetExecSummaryReq) IsSetSessionHandle added in v1.1.0 

func (p *TGetExecSummaryReq) IsSetSessionHandle() bool

func (*TGetExecSummaryReq) LogValue added in v1.1.0 

func (p *TGetExecSummaryReq) LogValue() slog.Value

func (*TGetExecSummaryReq) Read added in v1.1.0 

func (p *TGetExecSummaryReq) Read(ctx context.Context, iprot thrift.TProtocol) error

func (*TGetExecSummaryReq) ReadField1 added in v1.1.0 

func (p *TGetExecSummaryReq) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*TGetExecSummaryReq) ReadField2 added in v1.1.0 

func (p *TGetExecSummaryReq) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

func (*TGetExecSummaryReq) ReadField3 added in v1.1.0 

func (p *TGetExecSummaryReq) ReadField3(ctx context.Context, iprot thrift.TProtocol) error

func (*TGetExecSummaryReq) String added in v1.1.0 

func (p *TGetExecSummaryReq) String() string

func (*TGetExecSummaryReq) Validate added in v1.1.0 

func (p *TGetExecSummaryReq) Validate() error

func (*TGetExecSummaryReq) Write added in v1.1.0 

func (p *TGetExecSummaryReq) Write(ctx context.Context, oprot thrift.TProtocol) error

type TGetExecSummaryResp added in v1.1.0 

type TGetExecSummaryResp struct {
	Status          *cli_service.TStatus      `thrift:"status,1,required" db:"status" json:"status"`
	Summary         *execstats.TExecSummary   `thrift:"summary,2" db:"summary" json:"summary,omitempty"`
	FailedSummaries []*execstats.TExecSummary `thrift:"failed_summaries,3" db:"failed_summaries" json:"failed_summaries,omitempty"`
}

Attributes:

  • Status
  • Summary
  • FailedSummaries
var ImpalaHiveServer2ServiceGetExecSummaryResult_Success_DEFAULT *TGetExecSummaryResp

func NewTGetExecSummaryResp added in v1.1.0 

func NewTGetExecSummaryResp() *TGetExecSummaryResp

func (*TGetExecSummaryResp) Equals added in v1.1.0 

func (p *TGetExecSummaryResp) Equals(other *TGetExecSummaryResp) bool

func (*TGetExecSummaryResp) GetFailedSummaries added in v1.1.0 

func (p *TGetExecSummaryResp) GetFailedSummaries() []*execstats.TExecSummary

func (*TGetExecSummaryResp) GetStatus added in v1.1.0 

func (p *TGetExecSummaryResp) GetStatus() *cli_service.TStatus

func (*TGetExecSummaryResp) GetSummary added in v1.1.0 

func (p *TGetExecSummaryResp) GetSummary() *execstats.TExecSummary

func (*TGetExecSummaryResp) IsSetFailedSummaries added in v1.1.0 

func (p *TGetExecSummaryResp) IsSetFailedSummaries() bool

func (*TGetExecSummaryResp) IsSetStatus added in v1.1.0 

func (p *TGetExecSummaryResp) IsSetStatus() bool

func (*TGetExecSummaryResp) IsSetSummary added in v1.1.0 

func (p *TGetExecSummaryResp) IsSetSummary() bool

func (*TGetExecSummaryResp) LogValue added in v1.1.0 

func (p *TGetExecSummaryResp) LogValue() slog.Value

func (*TGetExecSummaryResp) Read added in v1.1.0 

func (p *TGetExecSummaryResp) Read(ctx context.Context, iprot thrift.TProtocol) error

func (*TGetExecSummaryResp) ReadField1 added in v1.1.0 

func (p *TGetExecSummaryResp) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*TGetExecSummaryResp) ReadField2 added in v1.1.0 

func (p *TGetExecSummaryResp) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

func (*TGetExecSummaryResp) ReadField3 added in v1.1.0 

func (p *TGetExecSummaryResp) ReadField3(ctx context.Context, iprot thrift.TProtocol) error

func (*TGetExecSummaryResp) String added in v1.1.0 

func (p *TGetExecSummaryResp) String() string

func (*TGetExecSummaryResp) Validate added in v1.1.0 

func (p *TGetExecSummaryResp) Validate() error

func (*TGetExecSummaryResp) Write added in v1.1.0 

func (p *TGetExecSummaryResp) Write(ctx context.Context, oprot thrift.TProtocol) error

type TPingImpalaHS2ServiceReq added in v1.1.0 

type TPingImpalaHS2ServiceReq struct {
	SessionHandle *cli_service.TSessionHandle `thrift:"sessionHandle,1,required" db:"sessionHandle" json:"sessionHandle"`
}

Attributes:

  • SessionHandle
var ImpalaHiveServer2ServicePingImpalaHS2ServiceArgs_Req_DEFAULT *TPingImpalaHS2ServiceReq

func NewTPingImpalaHS2ServiceReq added in v1.1.0 

func NewTPingImpalaHS2ServiceReq() *TPingImpalaHS2ServiceReq

func (*TPingImpalaHS2ServiceReq) Equals added in v1.1.0 

func (p *TPingImpalaHS2ServiceReq) Equals(other *TPingImpalaHS2ServiceReq) bool

func (*TPingImpalaHS2ServiceReq) GetSessionHandle added in v1.1.0 

func (p *TPingImpalaHS2ServiceReq) GetSessionHandle() *cli_service.TSessionHandle

func (*TPingImpalaHS2ServiceReq) IsSetSessionHandle added in v1.1.0 

func (p *TPingImpalaHS2ServiceReq) IsSetSessionHandle() bool

func (*TPingImpalaHS2ServiceReq) LogValue added in v1.1.0 

func (p *TPingImpalaHS2ServiceReq) LogValue() slog.Value

func (*TPingImpalaHS2ServiceReq) Read added in v1.1.0 

func (p *TPingImpalaHS2ServiceReq) Read(ctx context.Context, iprot thrift.TProtocol) error

func (*TPingImpalaHS2ServiceReq) ReadField1 added in v1.1.0 

func (p *TPingImpalaHS2ServiceReq) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*TPingImpalaHS2ServiceReq) String added in v1.1.0 

func (p *TPingImpalaHS2ServiceReq) String() string

func (*TPingImpalaHS2ServiceReq) Validate added in v1.1.0 

func (p *TPingImpalaHS2ServiceReq) Validate() error

func (*TPingImpalaHS2ServiceReq) Write added in v1.1.0 

func (p *TPingImpalaHS2ServiceReq) Write(ctx context.Context, oprot thrift.TProtocol) error

type TPingImpalaHS2ServiceResp added in v1.1.0 

type TPingImpalaHS2ServiceResp struct {
	Status           *cli_service.TStatus `thrift:"status,1,required" db:"status" json:"status"`
	Version          *string              `thrift:"version,2" db:"version" json:"version,omitempty"`
	WebserverAddress *string              `thrift:"webserver_address,3" db:"webserver_address" json:"webserver_address,omitempty"`
	Timestamp        *int64               `thrift:"timestamp,4" db:"timestamp" json:"timestamp,omitempty"`
}

Attributes:

  • Status
  • Version
  • WebserverAddress
  • Timestamp
var ImpalaHiveServer2ServicePingImpalaHS2ServiceResult_Success_DEFAULT *TPingImpalaHS2ServiceResp

func NewTPingImpalaHS2ServiceResp added in v1.1.0 

func NewTPingImpalaHS2ServiceResp() *TPingImpalaHS2ServiceResp

func (*TPingImpalaHS2ServiceResp) Equals added in v1.1.0 

func (p *TPingImpalaHS2ServiceResp) Equals(other *TPingImpalaHS2ServiceResp) bool

func (*TPingImpalaHS2ServiceResp) GetStatus added in v1.1.0 

func (p *TPingImpalaHS2ServiceResp) GetStatus() *cli_service.TStatus

func (*TPingImpalaHS2ServiceResp) GetTimestamp added in v1.1.0 

func (p *TPingImpalaHS2ServiceResp) GetTimestamp() int64

func (*TPingImpalaHS2ServiceResp) GetVersion added in v1.1.0 

func (p *TPingImpalaHS2ServiceResp) GetVersion() string

func (*TPingImpalaHS2ServiceResp) GetWebserverAddress added in v1.1.0 

func (p *TPingImpalaHS2ServiceResp) GetWebserverAddress() string

func (*TPingImpalaHS2ServiceResp) IsSetStatus added in v1.1.0 

func (p *TPingImpalaHS2ServiceResp) IsSetStatus() bool

func (*TPingImpalaHS2ServiceResp) IsSetTimestamp added in v1.1.0 

func (p *TPingImpalaHS2ServiceResp) IsSetTimestamp() bool

func (*TPingImpalaHS2ServiceResp) IsSetVersion added in v1.1.0 

func (p *TPingImpalaHS2ServiceResp) IsSetVersion() bool

func (*TPingImpalaHS2ServiceResp) IsSetWebserverAddress added in v1.1.0 

func (p *TPingImpalaHS2ServiceResp) IsSetWebserverAddress() bool

func (*TPingImpalaHS2ServiceResp) LogValue added in v1.1.0 

func (p *TPingImpalaHS2ServiceResp) LogValue() slog.Value

func (*TPingImpalaHS2ServiceResp) Read added in v1.1.0 

func (p *TPingImpalaHS2ServiceResp) Read(ctx context.Context, iprot thrift.TProtocol) error

func (*TPingImpalaHS2ServiceResp) ReadField1 added in v1.1.0 

func (p *TPingImpalaHS2ServiceResp) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*TPingImpalaHS2ServiceResp) ReadField2 added in v1.1.0 

func (p *TPingImpalaHS2ServiceResp) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

func (*TPingImpalaHS2ServiceResp) ReadField3 added in v1.1.0 

func (p *TPingImpalaHS2ServiceResp) ReadField3(ctx context.Context, iprot thrift.TProtocol) error

func (*TPingImpalaHS2ServiceResp) ReadField4 added in v1.1.0 

func (p *TPingImpalaHS2ServiceResp) ReadField4(ctx context.Context, iprot thrift.TProtocol) error

func (*TPingImpalaHS2ServiceResp) String added in v1.1.0 

func (p *TPingImpalaHS2ServiceResp) String() string

func (*TPingImpalaHS2ServiceResp) Validate added in v1.1.0 

func (p *TPingImpalaHS2ServiceResp) Validate() error

func (*TPingImpalaHS2ServiceResp) Write added in v1.1.0 

func (p *TPingImpalaHS2ServiceResp) Write(ctx context.Context, oprot thrift.TProtocol) error

type TPingImpalaServiceResp added in v1.1.0 

type TPingImpalaServiceResp struct {
	Version          string `thrift:"version,1" db:"version" json:"version"`
	WebserverAddress string `thrift:"webserver_address,2" db:"webserver_address" json:"webserver_address"`
}

Attributes:

  • Version
  • WebserverAddress

func NewTPingImpalaServiceResp added in v1.1.0 

func NewTPingImpalaServiceResp() *TPingImpalaServiceResp

func (*TPingImpalaServiceResp) Equals added in v1.1.0 

func (p *TPingImpalaServiceResp) Equals(other *TPingImpalaServiceResp) bool

func (*TPingImpalaServiceResp) GetVersion added in v1.1.0 

func (p *TPingImpalaServiceResp) GetVersion() string

func (*TPingImpalaServiceResp) GetWebserverAddress added in v1.1.0 

func (p *TPingImpalaServiceResp) GetWebserverAddress() string

func (*TPingImpalaServiceResp) LogValue added in v1.1.0 

func (p *TPingImpalaServiceResp) LogValue() slog.Value

func (*TPingImpalaServiceResp) Read added in v1.1.0 

func (p *TPingImpalaServiceResp) Read(ctx context.Context, iprot thrift.TProtocol) error

func (*TPingImpalaServiceResp) ReadField1 added in v1.1.0 

func (p *TPingImpalaServiceResp) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*TPingImpalaServiceResp) ReadField2 added in v1.1.0 

func (p *TPingImpalaServiceResp) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

func (*TPingImpalaServiceResp) String added in v1.1.0 

func (p *TPingImpalaServiceResp) String() string

func (*TPingImpalaServiceResp) Validate added in v1.1.0 

func (p *TPingImpalaServiceResp) Validate() error

func (*TPingImpalaServiceResp) Write added in v1.1.0 

func (p *TPingImpalaServiceResp) Write(ctx context.Context, oprot thrift.TProtocol) error

type TResetTableReq added in v1.1.0 

type TResetTableReq struct {
	DbName    string `thrift:"db_name,1,required" db:"db_name" json:"db_name"`
	TableName string `thrift:"table_name,2,required" db:"table_name" json:"table_name"`
}

Attributes:

  • DbName
  • TableName

func NewTResetTableReq added in v1.1.0 

func NewTResetTableReq() *TResetTableReq

func (*TResetTableReq) Equals added in v1.1.0 

func (p *TResetTableReq) Equals(other *TResetTableReq) bool

func (*TResetTableReq) GetDbName added in v1.1.0 

func (p *TResetTableReq) GetDbName() string

func (*TResetTableReq) GetTableName added in v1.1.0 

func (p *TResetTableReq) GetTableName() string

func (*TResetTableReq) LogValue added in v1.1.0 

func (p *TResetTableReq) LogValue() slog.Value

func (*TResetTableReq) Read added in v1.1.0 

func (p *TResetTableReq) Read(ctx context.Context, iprot thrift.TProtocol) error

func (*TResetTableReq) ReadField1 added in v1.1.0 

func (p *TResetTableReq) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*TResetTableReq) ReadField2 added in v1.1.0 

func (p *TResetTableReq) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

func (*TResetTableReq) String added in v1.1.0 

func (p *TResetTableReq) String() string

func (*TResetTableReq) Validate added in v1.1.0 

func (p *TResetTableReq) Validate() error

func (*TResetTableReq) Write added in v1.1.0 

func (p *TResetTableReq) Write(ctx context.Context, 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.