impalaservice

package
v2.1.0+incompatible Latest Latest
Warning

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

 Go to latest Published: Jan 13, 2021 License: MIT Imports: 10 Imported by: 44

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var DEFAULT_QUERY_OPTIONS map[TImpalaQueryOptions]string
View Source 
var GoUnusedProtection__ int
View Source 
var ImpalaHiveServer2ServiceResetCatalogResult_Success_DEFAULT *status.TStatus
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

Functions

This section is empty.

Types

type ImpalaHiveServer2Service 

type ImpalaHiveServer2Service interface {
	cli_service.TCLIService

	ResetCatalog(ctx context.Context) (r *status.TStatus, 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) ResetCatalog 

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

type ImpalaHiveServer2ServiceProcessor 

type ImpalaHiveServer2ServiceProcessor struct {
	*cli_service.TCLIServiceProcessor
}

func NewImpalaHiveServer2ServiceProcessor 

func NewImpalaHiveServer2ServiceProcessor(handler ImpalaHiveServer2Service) *ImpalaHiveServer2ServiceProcessor

type ImpalaHiveServer2ServiceResetCatalogArgs 

type ImpalaHiveServer2ServiceResetCatalogArgs struct {
}

func NewImpalaHiveServer2ServiceResetCatalogArgs 

func NewImpalaHiveServer2ServiceResetCatalogArgs() *ImpalaHiveServer2ServiceResetCatalogArgs

func (*ImpalaHiveServer2ServiceResetCatalogArgs) Read 

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

func (*ImpalaHiveServer2ServiceResetCatalogArgs) String 

func (p *ImpalaHiveServer2ServiceResetCatalogArgs) String() string

func (*ImpalaHiveServer2ServiceResetCatalogArgs) Write 

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

type ImpalaHiveServer2ServiceResetCatalogResult 

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

Attributes:

  • Success

func NewImpalaHiveServer2ServiceResetCatalogResult 

func NewImpalaHiveServer2ServiceResetCatalogResult() *ImpalaHiveServer2ServiceResetCatalogResult

func (*ImpalaHiveServer2ServiceResetCatalogResult) GetSuccess 

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

func (*ImpalaHiveServer2ServiceResetCatalogResult) IsSetSuccess 

func (p *ImpalaHiveServer2ServiceResetCatalogResult) IsSetSuccess() bool

func (*ImpalaHiveServer2ServiceResetCatalogResult) Read 

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

func (*ImpalaHiveServer2ServiceResetCatalogResult) ReadField0 

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

func (*ImpalaHiveServer2ServiceResetCatalogResult) String 

func (p *ImpalaHiveServer2ServiceResetCatalogResult) String() string

func (*ImpalaHiveServer2ServiceResetCatalogResult) Write 

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

type ImpalaService 

type ImpalaService interface {
	beeswax.BeeswaxService

	// Parameters:
	//  - QueryID
	Cancel(ctx context.Context, query_id *beeswax.QueryHandle) (r *status.TStatus, err error)
	// Parameters:
	//  - Handle
	CloseInsert(ctx context.Context, handle *beeswax.QueryHandle) (r *TInsertResult_, err error)
	PingImpalaService(ctx context.Context) (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) PingImpalaService 

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

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 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 {
}

func NewImpalaServicePingImpalaServiceResult 

func NewImpalaServicePingImpalaServiceResult() *ImpalaServicePingImpalaServiceResult

func (*ImpalaServicePingImpalaServiceResult) Read 

func (p *ImpalaServicePingImpalaServiceResult) Read(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 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
)

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

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.