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: 0

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

type ImpalaHiveServer2ServiceResetCatalogArgs

type ImpalaHiveServer2ServiceResetCatalogArgs struct {
}

func NewImpalaHiveServer2ServiceResetCatalogArgs

func NewImpalaHiveServer2ServiceResetCatalogArgs() *ImpalaHiveServer2ServiceResetCatalogArgs

func (*ImpalaHiveServer2ServiceResetCatalogArgs) Read

func (*ImpalaHiveServer2ServiceResetCatalogArgs) String

func (*ImpalaHiveServer2ServiceResetCatalogArgs) Write

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

func (*ImpalaHiveServer2ServiceResetCatalogResult) Read

func (*ImpalaHiveServer2ServiceResetCatalogResult) ReadField0

func (*ImpalaHiveServer2ServiceResetCatalogResult) String

func (*ImpalaHiveServer2ServiceResetCatalogResult) Write

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

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

func (*ImpalaServiceCancelArgs) String

func (p *ImpalaServiceCancelArgs) String() string

func (*ImpalaServiceCancelArgs) Write

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

type ImpalaServiceClient

type ImpalaServiceClient struct {
	*beeswax.BeeswaxServiceClient
}

func NewImpalaServiceClient

func NewImpalaServiceClient(c thrift.TClient) *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 (*ImpalaServiceCloseInsertArgs) IsSetHandle

func (p *ImpalaServiceCloseInsertArgs) IsSetHandle() bool

func (*ImpalaServiceCloseInsertArgs) Read

func (*ImpalaServiceCloseInsertArgs) ReadField1

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

func (*ImpalaServiceCloseInsertArgs) String

func (*ImpalaServiceCloseInsertArgs) Write

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

func (*ImpalaServiceCloseInsertResult) GetSuccess

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

func (*ImpalaServiceCloseInsertResult) ReadField1

func (*ImpalaServiceCloseInsertResult) ReadField2

func (*ImpalaServiceCloseInsertResult) String

func (*ImpalaServiceCloseInsertResult) Write

type ImpalaServicePingImpalaServiceArgs

type ImpalaServicePingImpalaServiceArgs struct {
}

func NewImpalaServicePingImpalaServiceArgs

func NewImpalaServicePingImpalaServiceArgs() *ImpalaServicePingImpalaServiceArgs

func (*ImpalaServicePingImpalaServiceArgs) Read

func (*ImpalaServicePingImpalaServiceArgs) String

func (*ImpalaServicePingImpalaServiceArgs) Write

type ImpalaServicePingImpalaServiceResult

type ImpalaServicePingImpalaServiceResult struct {
}

func NewImpalaServicePingImpalaServiceResult

func NewImpalaServicePingImpalaServiceResult() *ImpalaServicePingImpalaServiceResult

func (*ImpalaServicePingImpalaServiceResult) Read

func (*ImpalaServicePingImpalaServiceResult) String

func (*ImpalaServicePingImpalaServiceResult) Write

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

Directories

Path Synopsis

Jump to

Keyboard shortcuts

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