impalaservice

package
v1.0.0 Latest Latest
Warning

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

 Go to latest Published: May 6, 2020 License: MIT Imports: 12 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var GoUnusedProtection__ int
View Source 
var ImpalaServiceCancelArgs_QueryID_DEFAULT *beeswax.QueryHandle
View Source 
var ImpalaServiceCancelResult_Error_DEFAULT *beeswax.BeeswaxException
View Source 
var ImpalaServiceCancelResult_Success_DEFAULT *status.TStatus
View Source 
var ImpalaServiceCloseInsertArgs_Handle_DEFAULT *beeswax.QueryHandle
View Source 
var ImpalaServiceCloseInsertResult_Error2_DEFAULT *beeswax.BeeswaxException
View Source 
var ImpalaServiceCloseInsertResult_Error_DEFAULT *beeswax.QueryNotFoundException
View Source 
var ImpalaServiceGetExecSummaryArgs_Handle_DEFAULT *beeswax.QueryHandle
View Source 
var ImpalaServiceGetExecSummaryResult_Error2_DEFAULT *beeswax.BeeswaxException
View Source 
var ImpalaServiceGetExecSummaryResult_Error_DEFAULT *beeswax.QueryNotFoundException
View Source 
var ImpalaServiceGetExecSummaryResult_Success_DEFAULT *execstats.TExecSummary
View Source 
var ImpalaServiceGetRuntimeProfileArgs_QueryID_DEFAULT *beeswax.QueryHandle
View Source 
var ImpalaServiceGetRuntimeProfileResult_Error_DEFAULT *beeswax.BeeswaxException
View Source 
var ImpalaServiceGetRuntimeProfileResult_Success_DEFAULT string
View Source 
var ImpalaServiceResetCatalogResult_Success_DEFAULT *status.TStatus
View Source 
var ImpalaServiceResetTableResult_Success_DEFAULT *status.TStatus
View Source 
var TGetExecSummaryReq_OperationHandle_DEFAULT *tcliservice.TOperationHandle
View Source 
var TGetExecSummaryReq_SessionHandle_DEFAULT *tcliservice.TSessionHandle
View Source 
var TGetExecSummaryResp_Status_DEFAULT *tcliservice.TStatus
View Source 
var TGetExecSummaryResp_Summary_DEFAULT *execstats.TExecSummary
View Source 
var TGetRuntimeProfileReq_OperationHandle_DEFAULT *tcliservice.TOperationHandle
View Source 
var TGetRuntimeProfileReq_SessionHandle_DEFAULT *tcliservice.TSessionHandle
View Source 
var TGetRuntimeProfileResp_Profile_DEFAULT string
View Source 
var TGetRuntimeProfileResp_Status_DEFAULT *tcliservice.TStatus

Functions

This section is empty.

Types

type ImpalaHiveServer2Service 

type ImpalaHiveServer2Service interface {
	tcliservice.TCLIService

	// Parameters:
	//  - Req
	GetExecSummary(ctx context.Context, req *TGetExecSummaryReq) (r *TGetExecSummaryResp, err error)
	// Parameters:
	//  - Req
	GetRuntimeProfile(ctx context.Context, req *TGetRuntimeProfileReq) (r *TGetRuntimeProfileResp, err error)
}

type ImpalaHiveServer2ServiceClient 

type ImpalaHiveServer2ServiceClient struct {
	*tcliservice.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) GetExecSummary 

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

Parameters:

  • Req

func (*ImpalaHiveServer2ServiceClient) GetRuntimeProfile 

func (p *ImpalaHiveServer2ServiceClient) GetRuntimeProfile(ctx context.Context, req *TGetRuntimeProfileReq) (r *TGetRuntimeProfileResp, err error)

Parameters:

  • Req

type ImpalaHiveServer2ServiceGetExecSummaryArgs 

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

Attributes:

  • Req

func NewImpalaHiveServer2ServiceGetExecSummaryArgs 

func NewImpalaHiveServer2ServiceGetExecSummaryArgs() *ImpalaHiveServer2ServiceGetExecSummaryArgs

func (*ImpalaHiveServer2ServiceGetExecSummaryArgs) GetReq 

func (p *ImpalaHiveServer2ServiceGetExecSummaryArgs) GetReq() *TGetExecSummaryReq

func (*ImpalaHiveServer2ServiceGetExecSummaryArgs) IsSetReq 

func (p *ImpalaHiveServer2ServiceGetExecSummaryArgs) IsSetReq() bool

func (*ImpalaHiveServer2ServiceGetExecSummaryArgs) Read 

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

func (*ImpalaHiveServer2ServiceGetExecSummaryArgs) ReadField1 

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

func (*ImpalaHiveServer2ServiceGetExecSummaryArgs) String 

func (p *ImpalaHiveServer2ServiceGetExecSummaryArgs) String() string

func (*ImpalaHiveServer2ServiceGetExecSummaryArgs) Write 

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

type ImpalaHiveServer2ServiceGetExecSummaryResult 

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

Attributes:

  • Success

func NewImpalaHiveServer2ServiceGetExecSummaryResult 

func NewImpalaHiveServer2ServiceGetExecSummaryResult() *ImpalaHiveServer2ServiceGetExecSummaryResult

func (*ImpalaHiveServer2ServiceGetExecSummaryResult) GetSuccess 

func (p *ImpalaHiveServer2ServiceGetExecSummaryResult) GetSuccess() *TGetExecSummaryResp

func (*ImpalaHiveServer2ServiceGetExecSummaryResult) IsSetSuccess 

func (p *ImpalaHiveServer2ServiceGetExecSummaryResult) IsSetSuccess() bool

func (*ImpalaHiveServer2ServiceGetExecSummaryResult) Read 

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

func (*ImpalaHiveServer2ServiceGetExecSummaryResult) ReadField0 

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

func (*ImpalaHiveServer2ServiceGetExecSummaryResult) String 

func (p *ImpalaHiveServer2ServiceGetExecSummaryResult) String() string

func (*ImpalaHiveServer2ServiceGetExecSummaryResult) Write 

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

type ImpalaHiveServer2ServiceGetRuntimeProfileArgs 

type ImpalaHiveServer2ServiceGetRuntimeProfileArgs struct {
	Req *TGetRuntimeProfileReq `thrift:"req,1" db:"req" json:"req"`
}

Attributes:

  • Req

func NewImpalaHiveServer2ServiceGetRuntimeProfileArgs 

func NewImpalaHiveServer2ServiceGetRuntimeProfileArgs() *ImpalaHiveServer2ServiceGetRuntimeProfileArgs

func (*ImpalaHiveServer2ServiceGetRuntimeProfileArgs) GetReq 

func (p *ImpalaHiveServer2ServiceGetRuntimeProfileArgs) GetReq() *TGetRuntimeProfileReq

func (*ImpalaHiveServer2ServiceGetRuntimeProfileArgs) IsSetReq 

func (p *ImpalaHiveServer2ServiceGetRuntimeProfileArgs) IsSetReq() bool

func (*ImpalaHiveServer2ServiceGetRuntimeProfileArgs) Read 

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

func (*ImpalaHiveServer2ServiceGetRuntimeProfileArgs) ReadField1 

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

func (*ImpalaHiveServer2ServiceGetRuntimeProfileArgs) String 

func (p *ImpalaHiveServer2ServiceGetRuntimeProfileArgs) String() string

func (*ImpalaHiveServer2ServiceGetRuntimeProfileArgs) Write 

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

type ImpalaHiveServer2ServiceGetRuntimeProfileResult 

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

Attributes:

  • Success

func NewImpalaHiveServer2ServiceGetRuntimeProfileResult 

func NewImpalaHiveServer2ServiceGetRuntimeProfileResult() *ImpalaHiveServer2ServiceGetRuntimeProfileResult

func (*ImpalaHiveServer2ServiceGetRuntimeProfileResult) GetSuccess 

func (p *ImpalaHiveServer2ServiceGetRuntimeProfileResult) GetSuccess() *TGetRuntimeProfileResp

func (*ImpalaHiveServer2ServiceGetRuntimeProfileResult) IsSetSuccess 

func (p *ImpalaHiveServer2ServiceGetRuntimeProfileResult) IsSetSuccess() bool

func (*ImpalaHiveServer2ServiceGetRuntimeProfileResult) Read 

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

func (*ImpalaHiveServer2ServiceGetRuntimeProfileResult) ReadField0 

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

func (*ImpalaHiveServer2ServiceGetRuntimeProfileResult) String 

func (p *ImpalaHiveServer2ServiceGetRuntimeProfileResult) String() string

func (*ImpalaHiveServer2ServiceGetRuntimeProfileResult) Write 

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

type ImpalaHiveServer2ServiceProcessor 

type ImpalaHiveServer2ServiceProcessor struct {
	*tcliservice.TCLIServiceProcessor
}

func NewImpalaHiveServer2ServiceProcessor 

func NewImpalaHiveServer2ServiceProcessor(handler ImpalaHiveServer2Service) *ImpalaHiveServer2ServiceProcessor

type ImpalaService 

type ImpalaService interface {
	beeswax.BeeswaxService

	// Parameters:
	//  - QueryID
	Cancel(ctx context.Context, query_id *beeswax.QueryHandle) (r *status.TStatus, err error)
	ResetCatalog(ctx context.Context) (r *status.TStatus, err error)
	// Parameters:
	//  - Request
	ResetTable(ctx context.Context, request *TResetTableReq) (r *status.TStatus, err error)
	// Parameters:
	//  - QueryID
	GetRuntimeProfile(ctx context.Context, query_id *beeswax.QueryHandle) (r string, err error)
	// Parameters:
	//  - Handle
	CloseInsert(ctx context.Context, handle *beeswax.QueryHandle) (r *TInsertResult_, err error)
	PingImpalaService(ctx context.Context) (r *TPingImpalaServiceResp, err error)
	// Parameters:
	//  - Handle
	GetExecSummary(ctx context.Context, handle *beeswax.QueryHandle) (r *execstats.TExecSummary, err error)
}

type ImpalaServiceCancelArgs 

type ImpalaServiceCancelArgs struct {
	QueryID *beeswax.QueryHandle `thrift:"query_id,1" db:"query_id" json:"query_id"`
}

Attributes:

  • QueryID

func NewImpalaServiceCancelArgs 

func NewImpalaServiceCancelArgs() *ImpalaServiceCancelArgs

func (*ImpalaServiceCancelArgs) GetQueryID 

func (p *ImpalaServiceCancelArgs) GetQueryID() *beeswax.QueryHandle

func (*ImpalaServiceCancelArgs) IsSetQueryID 

func (p *ImpalaServiceCancelArgs) IsSetQueryID() bool

func (*ImpalaServiceCancelArgs) Read 

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

func (*ImpalaServiceCancelArgs) ReadField1 

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

func (*ImpalaServiceCancelArgs) String 

func (p *ImpalaServiceCancelArgs) String() string

func (*ImpalaServiceCancelArgs) Write 

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

type ImpalaServiceCancelResult 

type ImpalaServiceCancelResult struct {
	Success *status.TStatus           `thrift:"success,0" db:"success" json:"success,omitempty"`
	Error   *beeswax.BeeswaxException `thrift:"error,1" db:"error" json:"error,omitempty"`
}

Attributes:

  • Success
  • Error

func NewImpalaServiceCancelResult 

func NewImpalaServiceCancelResult() *ImpalaServiceCancelResult

func (*ImpalaServiceCancelResult) GetError 

func (p *ImpalaServiceCancelResult) GetError() *beeswax.BeeswaxException

func (*ImpalaServiceCancelResult) GetSuccess 

func (p *ImpalaServiceCancelResult) GetSuccess() *status.TStatus

func (*ImpalaServiceCancelResult) IsSetError 

func (p *ImpalaServiceCancelResult) IsSetError() bool

func (*ImpalaServiceCancelResult) IsSetSuccess 

func (p *ImpalaServiceCancelResult) IsSetSuccess() bool

func (*ImpalaServiceCancelResult) Read 

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

func (*ImpalaServiceCancelResult) ReadField0 

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

func (*ImpalaServiceCancelResult) ReadField1 

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

func (*ImpalaServiceCancelResult) String 

func (p *ImpalaServiceCancelResult) String() string

func (*ImpalaServiceCancelResult) Write 

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

type ImpalaServiceClient 

type ImpalaServiceClient struct {
	*beeswax.BeeswaxServiceClient
}

func NewImpalaServiceClient 

func NewImpalaServiceClient(c thrift.TClient) *ImpalaServiceClient

func NewImpalaServiceClientFactory 

func NewImpalaServiceClientFactory(t thrift.TTransport, f thrift.TProtocolFactory) *ImpalaServiceClient

func NewImpalaServiceClientProtocol 

func NewImpalaServiceClientProtocol(t thrift.TTransport, iprot thrift.TProtocol, oprot thrift.TProtocol) *ImpalaServiceClient

func (*ImpalaServiceClient) Cancel 

func (p *ImpalaServiceClient) Cancel(ctx context.Context, query_id *beeswax.QueryHandle) (r *status.TStatus, err error)

Parameters:

  • QueryID

func (*ImpalaServiceClient) CloseInsert 

func (p *ImpalaServiceClient) CloseInsert(ctx context.Context, handle *beeswax.QueryHandle) (r *TInsertResult_, err error)

Parameters:

  • Handle

func (*ImpalaServiceClient) GetExecSummary 

func (p *ImpalaServiceClient) GetExecSummary(ctx context.Context, handle *beeswax.QueryHandle) (r *execstats.TExecSummary, err error)

Parameters:

  • Handle

func (*ImpalaServiceClient) GetRuntimeProfile 

func (p *ImpalaServiceClient) GetRuntimeProfile(ctx context.Context, query_id *beeswax.QueryHandle) (r string, err error)

Parameters:

  • QueryID

func (*ImpalaServiceClient) PingImpalaService 

func (p *ImpalaServiceClient) PingImpalaService(ctx context.Context) (r *TPingImpalaServiceResp, err error)

func (*ImpalaServiceClient) ResetCatalog 

func (p *ImpalaServiceClient) ResetCatalog(ctx context.Context) (r *status.TStatus, err error)

func (*ImpalaServiceClient) ResetTable 

func (p *ImpalaServiceClient) ResetTable(ctx context.Context, request *TResetTableReq) (r *status.TStatus, err error)

Parameters:

  • Request

type ImpalaServiceCloseInsertArgs 

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

Attributes:

  • Handle

func NewImpalaServiceCloseInsertArgs 

func NewImpalaServiceCloseInsertArgs() *ImpalaServiceCloseInsertArgs

func (*ImpalaServiceCloseInsertArgs) GetHandle 

func (p *ImpalaServiceCloseInsertArgs) GetHandle() *beeswax.QueryHandle

func (*ImpalaServiceCloseInsertArgs) IsSetHandle 

func (p *ImpalaServiceCloseInsertArgs) IsSetHandle() bool

func (*ImpalaServiceCloseInsertArgs) Read 

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

func (*ImpalaServiceCloseInsertArgs) ReadField1 

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

func (*ImpalaServiceCloseInsertArgs) String 

func (p *ImpalaServiceCloseInsertArgs) String() string

func (*ImpalaServiceCloseInsertArgs) Write 

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

type ImpalaServiceCloseInsertResult 

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

Attributes:

  • Success
  • Error
  • Error2

func NewImpalaServiceCloseInsertResult 

func NewImpalaServiceCloseInsertResult() *ImpalaServiceCloseInsertResult

func (*ImpalaServiceCloseInsertResult) GetError 

func (p *ImpalaServiceCloseInsertResult) GetError() *beeswax.QueryNotFoundException

func (*ImpalaServiceCloseInsertResult) GetError2 

func (p *ImpalaServiceCloseInsertResult) GetError2() *beeswax.BeeswaxException

func (*ImpalaServiceCloseInsertResult) GetSuccess 

func (p *ImpalaServiceCloseInsertResult) GetSuccess() *TInsertResult_

func (*ImpalaServiceCloseInsertResult) IsSetError 

func (p *ImpalaServiceCloseInsertResult) IsSetError() bool

func (*ImpalaServiceCloseInsertResult) IsSetError2 

func (p *ImpalaServiceCloseInsertResult) IsSetError2() bool

func (*ImpalaServiceCloseInsertResult) IsSetSuccess 

func (p *ImpalaServiceCloseInsertResult) IsSetSuccess() bool

func (*ImpalaServiceCloseInsertResult) Read 

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

func (*ImpalaServiceCloseInsertResult) ReadField0 

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

func (*ImpalaServiceCloseInsertResult) ReadField1 

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

func (*ImpalaServiceCloseInsertResult) ReadField2 

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

func (*ImpalaServiceCloseInsertResult) String 

func (p *ImpalaServiceCloseInsertResult) String() string

func (*ImpalaServiceCloseInsertResult) Write 

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

type ImpalaServiceGetExecSummaryArgs 

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

Attributes:

  • Handle

func NewImpalaServiceGetExecSummaryArgs 

func NewImpalaServiceGetExecSummaryArgs() *ImpalaServiceGetExecSummaryArgs

func (*ImpalaServiceGetExecSummaryArgs) GetHandle 

func (p *ImpalaServiceGetExecSummaryArgs) GetHandle() *beeswax.QueryHandle

func (*ImpalaServiceGetExecSummaryArgs) IsSetHandle 

func (p *ImpalaServiceGetExecSummaryArgs) IsSetHandle() bool

func (*ImpalaServiceGetExecSummaryArgs) Read 

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

func (*ImpalaServiceGetExecSummaryArgs) ReadField1 

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

func (*ImpalaServiceGetExecSummaryArgs) String 

func (p *ImpalaServiceGetExecSummaryArgs) String() string

func (*ImpalaServiceGetExecSummaryArgs) Write 

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

type ImpalaServiceGetExecSummaryResult 

type ImpalaServiceGetExecSummaryResult struct {
	Success *execstats.TExecSummary         `thrift:"success,0" db:"success" json:"success,omitempty"`
	Error   *beeswax.QueryNotFoundException `thrift:"error,1" db:"error" json:"error,omitempty"`
	Error2  *beeswax.BeeswaxException       `thrift:"error2,2" db:"error2" json:"error2,omitempty"`
}

Attributes:

  • Success
  • Error
  • Error2

func NewImpalaServiceGetExecSummaryResult 

func NewImpalaServiceGetExecSummaryResult() *ImpalaServiceGetExecSummaryResult

func (*ImpalaServiceGetExecSummaryResult) GetError 

func (p *ImpalaServiceGetExecSummaryResult) GetError() *beeswax.QueryNotFoundException

func (*ImpalaServiceGetExecSummaryResult) GetError2 

func (p *ImpalaServiceGetExecSummaryResult) GetError2() *beeswax.BeeswaxException

func (*ImpalaServiceGetExecSummaryResult) GetSuccess 

func (p *ImpalaServiceGetExecSummaryResult) GetSuccess() *execstats.TExecSummary

func (*ImpalaServiceGetExecSummaryResult) IsSetError 

func (p *ImpalaServiceGetExecSummaryResult) IsSetError() bool

func (*ImpalaServiceGetExecSummaryResult) IsSetError2 

func (p *ImpalaServiceGetExecSummaryResult) IsSetError2() bool

func (*ImpalaServiceGetExecSummaryResult) IsSetSuccess 

func (p *ImpalaServiceGetExecSummaryResult) IsSetSuccess() bool

func (*ImpalaServiceGetExecSummaryResult) Read 

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

func (*ImpalaServiceGetExecSummaryResult) ReadField0 

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

func (*ImpalaServiceGetExecSummaryResult) ReadField1 

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

func (*ImpalaServiceGetExecSummaryResult) ReadField2 

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

func (*ImpalaServiceGetExecSummaryResult) String 

func (p *ImpalaServiceGetExecSummaryResult) String() string

func (*ImpalaServiceGetExecSummaryResult) Write 

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

type ImpalaServiceGetRuntimeProfileArgs 

type ImpalaServiceGetRuntimeProfileArgs struct {
	QueryID *beeswax.QueryHandle `thrift:"query_id,1" db:"query_id" json:"query_id"`
}

Attributes:

  • QueryID

func NewImpalaServiceGetRuntimeProfileArgs 

func NewImpalaServiceGetRuntimeProfileArgs() *ImpalaServiceGetRuntimeProfileArgs

func (*ImpalaServiceGetRuntimeProfileArgs) GetQueryID 

func (p *ImpalaServiceGetRuntimeProfileArgs) GetQueryID() *beeswax.QueryHandle

func (*ImpalaServiceGetRuntimeProfileArgs) IsSetQueryID 

func (p *ImpalaServiceGetRuntimeProfileArgs) IsSetQueryID() bool

func (*ImpalaServiceGetRuntimeProfileArgs) Read 

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

func (*ImpalaServiceGetRuntimeProfileArgs) ReadField1 

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

func (*ImpalaServiceGetRuntimeProfileArgs) String 

func (p *ImpalaServiceGetRuntimeProfileArgs) String() string

func (*ImpalaServiceGetRuntimeProfileArgs) Write 

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

type ImpalaServiceGetRuntimeProfileResult 

type ImpalaServiceGetRuntimeProfileResult struct {
	Success *string                   `thrift:"success,0" db:"success" json:"success,omitempty"`
	Error   *beeswax.BeeswaxException `thrift:"error,1" db:"error" json:"error,omitempty"`
}

Attributes:

  • Success
  • Error

func NewImpalaServiceGetRuntimeProfileResult 

func NewImpalaServiceGetRuntimeProfileResult() *ImpalaServiceGetRuntimeProfileResult

func (*ImpalaServiceGetRuntimeProfileResult) GetError 

func (p *ImpalaServiceGetRuntimeProfileResult) GetError() *beeswax.BeeswaxException

func (*ImpalaServiceGetRuntimeProfileResult) GetSuccess 

func (p *ImpalaServiceGetRuntimeProfileResult) GetSuccess() string

func (*ImpalaServiceGetRuntimeProfileResult) IsSetError 

func (p *ImpalaServiceGetRuntimeProfileResult) IsSetError() bool

func (*ImpalaServiceGetRuntimeProfileResult) IsSetSuccess 

func (p *ImpalaServiceGetRuntimeProfileResult) IsSetSuccess() bool

func (*ImpalaServiceGetRuntimeProfileResult) Read 

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

func (*ImpalaServiceGetRuntimeProfileResult) ReadField0 

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

func (*ImpalaServiceGetRuntimeProfileResult) ReadField1 

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

func (*ImpalaServiceGetRuntimeProfileResult) String 

func (p *ImpalaServiceGetRuntimeProfileResult) String() string

func (*ImpalaServiceGetRuntimeProfileResult) Write 

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

type ImpalaServicePingImpalaServiceArgs 

type ImpalaServicePingImpalaServiceArgs struct {
}

func NewImpalaServicePingImpalaServiceArgs 

func NewImpalaServicePingImpalaServiceArgs() *ImpalaServicePingImpalaServiceArgs

func (*ImpalaServicePingImpalaServiceArgs) Read 

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

func (*ImpalaServicePingImpalaServiceArgs) String 

func (p *ImpalaServicePingImpalaServiceArgs) String() string

func (*ImpalaServicePingImpalaServiceArgs) Write 

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

type ImpalaServicePingImpalaServiceResult 

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

Attributes:

  • Success

func NewImpalaServicePingImpalaServiceResult 

func NewImpalaServicePingImpalaServiceResult() *ImpalaServicePingImpalaServiceResult

func (*ImpalaServicePingImpalaServiceResult) GetSuccess 

func (p *ImpalaServicePingImpalaServiceResult) GetSuccess() *TPingImpalaServiceResp

func (*ImpalaServicePingImpalaServiceResult) IsSetSuccess 

func (p *ImpalaServicePingImpalaServiceResult) IsSetSuccess() bool

func (*ImpalaServicePingImpalaServiceResult) Read 

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

func (*ImpalaServicePingImpalaServiceResult) ReadField0 

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

func (*ImpalaServicePingImpalaServiceResult) String 

func (p *ImpalaServicePingImpalaServiceResult) String() string

func (*ImpalaServicePingImpalaServiceResult) Write 

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

type ImpalaServiceProcessor 

type ImpalaServiceProcessor struct {
	*beeswax.BeeswaxServiceProcessor
}

func NewImpalaServiceProcessor 

func NewImpalaServiceProcessor(handler ImpalaService) *ImpalaServiceProcessor

type ImpalaServiceResetCatalogArgs 

type ImpalaServiceResetCatalogArgs struct {
}

func NewImpalaServiceResetCatalogArgs 

func NewImpalaServiceResetCatalogArgs() *ImpalaServiceResetCatalogArgs

func (*ImpalaServiceResetCatalogArgs) Read 

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

func (*ImpalaServiceResetCatalogArgs) String 

func (p *ImpalaServiceResetCatalogArgs) String() string

func (*ImpalaServiceResetCatalogArgs) Write 

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

type ImpalaServiceResetCatalogResult 

type ImpalaServiceResetCatalogResult struct {
	Success *status.TStatus `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewImpalaServiceResetCatalogResult 

func NewImpalaServiceResetCatalogResult() *ImpalaServiceResetCatalogResult

func (*ImpalaServiceResetCatalogResult) GetSuccess 

func (p *ImpalaServiceResetCatalogResult) GetSuccess() *status.TStatus

func (*ImpalaServiceResetCatalogResult) IsSetSuccess 

func (p *ImpalaServiceResetCatalogResult) IsSetSuccess() bool

func (*ImpalaServiceResetCatalogResult) Read 

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

func (*ImpalaServiceResetCatalogResult) ReadField0 

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

func (*ImpalaServiceResetCatalogResult) String 

func (p *ImpalaServiceResetCatalogResult) String() string

func (*ImpalaServiceResetCatalogResult) Write 

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

type ImpalaServiceResetTableArgs 

type ImpalaServiceResetTableArgs struct {
	Request *TResetTableReq `thrift:"request,1" db:"request" json:"request"`
}

Attributes:

  • Request

func NewImpalaServiceResetTableArgs 

func NewImpalaServiceResetTableArgs() *ImpalaServiceResetTableArgs

func (*ImpalaServiceResetTableArgs) GetRequest 

func (p *ImpalaServiceResetTableArgs) GetRequest() *TResetTableReq

func (*ImpalaServiceResetTableArgs) IsSetRequest 

func (p *ImpalaServiceResetTableArgs) IsSetRequest() bool

func (*ImpalaServiceResetTableArgs) Read 

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

func (*ImpalaServiceResetTableArgs) ReadField1 

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

func (*ImpalaServiceResetTableArgs) String 

func (p *ImpalaServiceResetTableArgs) String() string

func (*ImpalaServiceResetTableArgs) Write 

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

type ImpalaServiceResetTableResult 

type ImpalaServiceResetTableResult struct {
	Success *status.TStatus `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewImpalaServiceResetTableResult 

func NewImpalaServiceResetTableResult() *ImpalaServiceResetTableResult

func (*ImpalaServiceResetTableResult) GetSuccess 

func (p *ImpalaServiceResetTableResult) GetSuccess() *status.TStatus

func (*ImpalaServiceResetTableResult) IsSetSuccess 

func (p *ImpalaServiceResetTableResult) IsSetSuccess() bool

func (*ImpalaServiceResetTableResult) Read 

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

func (*ImpalaServiceResetTableResult) ReadField0 

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

func (*ImpalaServiceResetTableResult) String 

func (p *ImpalaServiceResetTableResult) String() string

func (*ImpalaServiceResetTableResult) Write 

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

type TGetExecSummaryReq 

type TGetExecSummaryReq struct {
	OperationHandle *tcliservice.TOperationHandle `thrift:"operationHandle,1" db:"operationHandle" json:"operationHandle,omitempty"`
	SessionHandle   *tcliservice.TSessionHandle   `thrift:"sessionHandle,2" db:"sessionHandle" json:"sessionHandle,omitempty"`
}

Attributes:

  • OperationHandle
  • SessionHandle
var ImpalaHiveServer2ServiceGetExecSummaryArgs_Req_DEFAULT *TGetExecSummaryReq

func NewTGetExecSummaryReq 

func NewTGetExecSummaryReq() *TGetExecSummaryReq

func (*TGetExecSummaryReq) GetOperationHandle 

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

func (*TGetExecSummaryReq) GetSessionHandle 

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

func (*TGetExecSummaryReq) IsSetOperationHandle 

func (p *TGetExecSummaryReq) IsSetOperationHandle() bool

func (*TGetExecSummaryReq) IsSetSessionHandle 

func (p *TGetExecSummaryReq) IsSetSessionHandle() bool

func (*TGetExecSummaryReq) Read 

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

func (*TGetExecSummaryReq) ReadField1 

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

func (*TGetExecSummaryReq) ReadField2 

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

func (*TGetExecSummaryReq) String 

func (p *TGetExecSummaryReq) String() string

func (*TGetExecSummaryReq) Write 

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

type TGetExecSummaryResp 

type TGetExecSummaryResp struct {
	Status  *tcliservice.TStatus    `thrift:"status,1,required" db:"status" json:"status"`
	Summary *execstats.TExecSummary `thrift:"summary,2" db:"summary" json:"summary,omitempty"`
}

Attributes:

  • Status
  • Summary
var ImpalaHiveServer2ServiceGetExecSummaryResult_Success_DEFAULT *TGetExecSummaryResp

func NewTGetExecSummaryResp 

func NewTGetExecSummaryResp() *TGetExecSummaryResp

func (*TGetExecSummaryResp) GetStatus 

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

func (*TGetExecSummaryResp) GetSummary 

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

func (*TGetExecSummaryResp) IsSetStatus 

func (p *TGetExecSummaryResp) IsSetStatus() bool

func (*TGetExecSummaryResp) IsSetSummary 

func (p *TGetExecSummaryResp) IsSetSummary() bool

func (*TGetExecSummaryResp) Read 

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

func (*TGetExecSummaryResp) ReadField1 

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

func (*TGetExecSummaryResp) ReadField2 

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

func (*TGetExecSummaryResp) String 

func (p *TGetExecSummaryResp) String() string

func (*TGetExecSummaryResp) Write 

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

type TGetRuntimeProfileReq 

type TGetRuntimeProfileReq struct {
	OperationHandle *tcliservice.TOperationHandle `thrift:"operationHandle,1" db:"operationHandle" json:"operationHandle,omitempty"`
	SessionHandle   *tcliservice.TSessionHandle   `thrift:"sessionHandle,2" db:"sessionHandle" json:"sessionHandle,omitempty"`
}

Attributes:

  • OperationHandle
  • SessionHandle
var ImpalaHiveServer2ServiceGetRuntimeProfileArgs_Req_DEFAULT *TGetRuntimeProfileReq

func NewTGetRuntimeProfileReq 

func NewTGetRuntimeProfileReq() *TGetRuntimeProfileReq

func (*TGetRuntimeProfileReq) GetOperationHandle 

func (p *TGetRuntimeProfileReq) GetOperationHandle() *tcliservice.TOperationHandle

func (*TGetRuntimeProfileReq) GetSessionHandle 

func (p *TGetRuntimeProfileReq) GetSessionHandle() *tcliservice.TSessionHandle

func (*TGetRuntimeProfileReq) IsSetOperationHandle 

func (p *TGetRuntimeProfileReq) IsSetOperationHandle() bool

func (*TGetRuntimeProfileReq) IsSetSessionHandle 

func (p *TGetRuntimeProfileReq) IsSetSessionHandle() bool

func (*TGetRuntimeProfileReq) Read 

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

func (*TGetRuntimeProfileReq) ReadField1 

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

func (*TGetRuntimeProfileReq) ReadField2 

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

func (*TGetRuntimeProfileReq) String 

func (p *TGetRuntimeProfileReq) String() string

func (*TGetRuntimeProfileReq) Write 

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

type TGetRuntimeProfileResp 

type TGetRuntimeProfileResp struct {
	Status  *tcliservice.TStatus `thrift:"status,1,required" db:"status" json:"status"`
	Profile *string              `thrift:"profile,2" db:"profile" json:"profile,omitempty"`
}

Attributes:

  • Status
  • Profile
var ImpalaHiveServer2ServiceGetRuntimeProfileResult_Success_DEFAULT *TGetRuntimeProfileResp

func NewTGetRuntimeProfileResp 

func NewTGetRuntimeProfileResp() *TGetRuntimeProfileResp

func (*TGetRuntimeProfileResp) GetProfile 

func (p *TGetRuntimeProfileResp) GetProfile() string

func (*TGetRuntimeProfileResp) GetStatus 

func (p *TGetRuntimeProfileResp) GetStatus() *tcliservice.TStatus

func (*TGetRuntimeProfileResp) IsSetProfile 

func (p *TGetRuntimeProfileResp) IsSetProfile() bool

func (*TGetRuntimeProfileResp) IsSetStatus 

func (p *TGetRuntimeProfileResp) IsSetStatus() bool

func (*TGetRuntimeProfileResp) Read 

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

func (*TGetRuntimeProfileResp) ReadField1 

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

func (*TGetRuntimeProfileResp) ReadField2 

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

func (*TGetRuntimeProfileResp) String 

func (p *TGetRuntimeProfileResp) String() string

func (*TGetRuntimeProfileResp) Write 

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

type TImpalaQueryOptions 

type TImpalaQueryOptions int64
const (
	TImpalaQueryOptions_ABORT_ON_ERROR                  TImpalaQueryOptions = 0
	TImpalaQueryOptions_MAX_ERRORS                      TImpalaQueryOptions = 1
	TImpalaQueryOptions_DISABLE_CODEGEN                 TImpalaQueryOptions = 2
	TImpalaQueryOptions_BATCH_SIZE                      TImpalaQueryOptions = 3
	TImpalaQueryOptions_MEM_LIMIT                       TImpalaQueryOptions = 4
	TImpalaQueryOptions_NUM_NODES                       TImpalaQueryOptions = 5
	TImpalaQueryOptions_MAX_SCAN_RANGE_LENGTH           TImpalaQueryOptions = 6
	TImpalaQueryOptions_MAX_IO_BUFFERS                  TImpalaQueryOptions = 7
	TImpalaQueryOptions_NUM_SCANNER_THREADS             TImpalaQueryOptions = 8
	TImpalaQueryOptions_ALLOW_UNSUPPORTED_FORMATS       TImpalaQueryOptions = 9
	TImpalaQueryOptions_DEFAULT_ORDER_BY_LIMIT          TImpalaQueryOptions = 10
	TImpalaQueryOptions_DEBUG_ACTION                    TImpalaQueryOptions = 11
	TImpalaQueryOptions_ABORT_ON_DEFAULT_LIMIT_EXCEEDED TImpalaQueryOptions = 12
	TImpalaQueryOptions_COMPRESSION_CODEC               TImpalaQueryOptions = 13
	TImpalaQueryOptions_HBASE_CACHING                   TImpalaQueryOptions = 14
	TImpalaQueryOptions_HBASE_CACHE_BLOCKS              TImpalaQueryOptions = 15
	TImpalaQueryOptions_PARQUET_FILE_SIZE               TImpalaQueryOptions = 16
	TImpalaQueryOptions_EXPLAIN_LEVEL                   TImpalaQueryOptions = 17
	TImpalaQueryOptions_SYNC_DDL                        TImpalaQueryOptions = 18
	TImpalaQueryOptions_REQUEST_POOL                    TImpalaQueryOptions = 19
	TImpalaQueryOptions_V_CPU_CORES                     TImpalaQueryOptions = 20
	TImpalaQueryOptions_RESERVATION_REQUEST_TIMEOUT     TImpalaQueryOptions = 21
	TImpalaQueryOptions_DISABLE_CACHED_READS            TImpalaQueryOptions = 22
	TImpalaQueryOptions_DISABLE_OUTERMOST_TOPN          TImpalaQueryOptions = 23
	TImpalaQueryOptions_RM_INITIAL_MEM                  TImpalaQueryOptions = 24
	TImpalaQueryOptions_QUERY_TIMEOUT_S                 TImpalaQueryOptions = 25
	TImpalaQueryOptions_MAX_BLOCK_MGR_MEMORY            TImpalaQueryOptions = 26
	TImpalaQueryOptions_APPX_COUNT_DISTINCT             TImpalaQueryOptions = 27
	TImpalaQueryOptions_DISABLE_UNSAFE_SPILLS           TImpalaQueryOptions = 28
)

func TImpalaQueryOptionsFromString 

func TImpalaQueryOptionsFromString(s string) (TImpalaQueryOptions, error)

func TImpalaQueryOptionsPtr 

func TImpalaQueryOptionsPtr(v TImpalaQueryOptions) *TImpalaQueryOptions

func (TImpalaQueryOptions) MarshalText 

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

func (*TImpalaQueryOptions) Scan 

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

func (TImpalaQueryOptions) String 

func (p TImpalaQueryOptions) String() string

func (*TImpalaQueryOptions) UnmarshalText 

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

func (*TImpalaQueryOptions) Value 

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

type TInsertResult_ 

type TInsertResult_ struct {
	RowsAppended map[string]int64 `thrift:"rows_appended,1,required" db:"rows_appended" json:"rows_appended"`
}

Attributes:

  • RowsAppended
var ImpalaServiceCloseInsertResult_Success_DEFAULT *TInsertResult_

func NewTInsertResult_ 

func NewTInsertResult_() *TInsertResult_

func (*TInsertResult_) GetRowsAppended 

func (p *TInsertResult_) GetRowsAppended() map[string]int64

func (*TInsertResult_) Read 

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

func (*TInsertResult_) ReadField1 

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

func (*TInsertResult_) String 

func (p *TInsertResult_) String() string

func (*TInsertResult_) Write 

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

type TPingImpalaServiceResp 

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

Attributes:

  • Version
var ImpalaServicePingImpalaServiceResult_Success_DEFAULT *TPingImpalaServiceResp

func NewTPingImpalaServiceResp 

func NewTPingImpalaServiceResp() *TPingImpalaServiceResp

func (*TPingImpalaServiceResp) GetVersion 

func (p *TPingImpalaServiceResp) GetVersion() string

func (*TPingImpalaServiceResp) Read 

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

func (*TPingImpalaServiceResp) ReadField1 

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

func (*TPingImpalaServiceResp) String 

func (p *TPingImpalaServiceResp) String() string

func (*TPingImpalaServiceResp) Write 

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

type TResetTableReq 

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
var ImpalaServiceResetTableArgs_Request_DEFAULT *TResetTableReq

func NewTResetTableReq 

func NewTResetTableReq() *TResetTableReq

func (*TResetTableReq) GetDbName 

func (p *TResetTableReq) GetDbName() string

func (*TResetTableReq) GetTableName 

func (p *TResetTableReq) GetTableName() string

func (*TResetTableReq) Read 

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

func (*TResetTableReq) ReadField1 

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

func (*TResetTableReq) ReadField2 

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

func (*TResetTableReq) String 

func (p *TResetTableReq) String() string

func (*TResetTableReq) Write 

func (p *TResetTableReq) 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.