Versions in this module Expand all Collapse all v1 v1.0.0 Feb 15, 2019 Changes in this version + var DEFAULT_QUERY_OPTIONS map[TImpalaQueryOptions]string + var GoUnusedProtection__ int + var ImpalaHiveServer2ServiceResetCatalogResult_Success_DEFAULT *status.TStatus + var ImpalaServiceCancelArgs_QueryID_DEFAULT *beeswax.QueryHandle + var ImpalaServiceCancelResult_Error_DEFAULT *beeswax.BeeswaxException + var ImpalaServiceCancelResult_Success_DEFAULT *status.TStatus + var ImpalaServiceCloseInsertArgs_Handle_DEFAULT *beeswax.QueryHandle + var ImpalaServiceCloseInsertResult_Error2_DEFAULT *beeswax.BeeswaxException + var ImpalaServiceCloseInsertResult_Error_DEFAULT *beeswax.QueryNotFoundException + type ImpalaHiveServer2Service interface + ResetCatalog func(ctx context.Context) (r *status.TStatus, err error) + type ImpalaHiveServer2ServiceClient struct + func NewImpalaHiveServer2ServiceClient(c thrift.TClient) *ImpalaHiveServer2ServiceClient + func NewImpalaHiveServer2ServiceClientFactory(t thrift.TTransport, f thrift.TProtocolFactory) *ImpalaHiveServer2ServiceClient + func NewImpalaHiveServer2ServiceClientProtocol(t thrift.TTransport, iprot thrift.TProtocol, oprot thrift.TProtocol) *ImpalaHiveServer2ServiceClient + func (p *ImpalaHiveServer2ServiceClient) ResetCatalog(ctx context.Context) (r *status.TStatus, err error) + type ImpalaHiveServer2ServiceProcessor struct + func NewImpalaHiveServer2ServiceProcessor(handler ImpalaHiveServer2Service) *ImpalaHiveServer2ServiceProcessor + type ImpalaHiveServer2ServiceResetCatalogArgs struct + func NewImpalaHiveServer2ServiceResetCatalogArgs() *ImpalaHiveServer2ServiceResetCatalogArgs + func (p *ImpalaHiveServer2ServiceResetCatalogArgs) Read(iprot thrift.TProtocol) error + func (p *ImpalaHiveServer2ServiceResetCatalogArgs) String() string + func (p *ImpalaHiveServer2ServiceResetCatalogArgs) Write(oprot thrift.TProtocol) error + type ImpalaHiveServer2ServiceResetCatalogResult struct + Success *status.TStatus + func NewImpalaHiveServer2ServiceResetCatalogResult() *ImpalaHiveServer2ServiceResetCatalogResult + func (p *ImpalaHiveServer2ServiceResetCatalogResult) GetSuccess() *status.TStatus + func (p *ImpalaHiveServer2ServiceResetCatalogResult) IsSetSuccess() bool + func (p *ImpalaHiveServer2ServiceResetCatalogResult) Read(iprot thrift.TProtocol) error + func (p *ImpalaHiveServer2ServiceResetCatalogResult) ReadField0(iprot thrift.TProtocol) error + func (p *ImpalaHiveServer2ServiceResetCatalogResult) String() string + func (p *ImpalaHiveServer2ServiceResetCatalogResult) Write(oprot thrift.TProtocol) error + type ImpalaService interface + Cancel func(ctx context.Context, query_id *beeswax.QueryHandle) (r *status.TStatus, err error) + CloseInsert func(ctx context.Context, handle *beeswax.QueryHandle) (r *TInsertResult_, err error) + PingImpalaService func(ctx context.Context) (err error) + type ImpalaServiceCancelArgs struct + QueryID *beeswax.QueryHandle + func NewImpalaServiceCancelArgs() *ImpalaServiceCancelArgs + func (p *ImpalaServiceCancelArgs) GetQueryID() *beeswax.QueryHandle + func (p *ImpalaServiceCancelArgs) IsSetQueryID() bool + func (p *ImpalaServiceCancelArgs) Read(iprot thrift.TProtocol) error + func (p *ImpalaServiceCancelArgs) ReadField1(iprot thrift.TProtocol) error + func (p *ImpalaServiceCancelArgs) String() string + func (p *ImpalaServiceCancelArgs) Write(oprot thrift.TProtocol) error + type ImpalaServiceCancelResult struct + Error *beeswax.BeeswaxException + Success *status.TStatus + func NewImpalaServiceCancelResult() *ImpalaServiceCancelResult + func (p *ImpalaServiceCancelResult) GetError() *beeswax.BeeswaxException + func (p *ImpalaServiceCancelResult) GetSuccess() *status.TStatus + func (p *ImpalaServiceCancelResult) IsSetError() bool + func (p *ImpalaServiceCancelResult) IsSetSuccess() bool + func (p *ImpalaServiceCancelResult) Read(iprot thrift.TProtocol) error + func (p *ImpalaServiceCancelResult) ReadField0(iprot thrift.TProtocol) error + func (p *ImpalaServiceCancelResult) ReadField1(iprot thrift.TProtocol) error + func (p *ImpalaServiceCancelResult) String() string + func (p *ImpalaServiceCancelResult) Write(oprot thrift.TProtocol) error + type ImpalaServiceClient struct + func NewImpalaServiceClient(c thrift.TClient) *ImpalaServiceClient + func NewImpalaServiceClientFactory(t thrift.TTransport, f thrift.TProtocolFactory) *ImpalaServiceClient + func NewImpalaServiceClientProtocol(t thrift.TTransport, iprot thrift.TProtocol, oprot thrift.TProtocol) *ImpalaServiceClient + func (p *ImpalaServiceClient) Cancel(ctx context.Context, query_id *beeswax.QueryHandle) (r *status.TStatus, err error) + func (p *ImpalaServiceClient) CloseInsert(ctx context.Context, handle *beeswax.QueryHandle) (r *TInsertResult_, err error) + func (p *ImpalaServiceClient) PingImpalaService(ctx context.Context) (err error) + type ImpalaServiceCloseInsertArgs struct + Handle *beeswax.QueryHandle + func NewImpalaServiceCloseInsertArgs() *ImpalaServiceCloseInsertArgs + func (p *ImpalaServiceCloseInsertArgs) GetHandle() *beeswax.QueryHandle + func (p *ImpalaServiceCloseInsertArgs) IsSetHandle() bool + func (p *ImpalaServiceCloseInsertArgs) Read(iprot thrift.TProtocol) error + func (p *ImpalaServiceCloseInsertArgs) ReadField1(iprot thrift.TProtocol) error + func (p *ImpalaServiceCloseInsertArgs) String() string + func (p *ImpalaServiceCloseInsertArgs) Write(oprot thrift.TProtocol) error + type ImpalaServiceCloseInsertResult struct + Error *beeswax.QueryNotFoundException + Error2 *beeswax.BeeswaxException + Success *TInsertResult_ + func NewImpalaServiceCloseInsertResult() *ImpalaServiceCloseInsertResult + func (p *ImpalaServiceCloseInsertResult) GetError() *beeswax.QueryNotFoundException + func (p *ImpalaServiceCloseInsertResult) GetError2() *beeswax.BeeswaxException + func (p *ImpalaServiceCloseInsertResult) GetSuccess() *TInsertResult_ + func (p *ImpalaServiceCloseInsertResult) IsSetError() bool + func (p *ImpalaServiceCloseInsertResult) IsSetError2() bool + func (p *ImpalaServiceCloseInsertResult) IsSetSuccess() bool + func (p *ImpalaServiceCloseInsertResult) Read(iprot thrift.TProtocol) error + func (p *ImpalaServiceCloseInsertResult) ReadField0(iprot thrift.TProtocol) error + func (p *ImpalaServiceCloseInsertResult) ReadField1(iprot thrift.TProtocol) error + func (p *ImpalaServiceCloseInsertResult) ReadField2(iprot thrift.TProtocol) error + func (p *ImpalaServiceCloseInsertResult) String() string + func (p *ImpalaServiceCloseInsertResult) Write(oprot thrift.TProtocol) error + type ImpalaServicePingImpalaServiceArgs struct + func NewImpalaServicePingImpalaServiceArgs() *ImpalaServicePingImpalaServiceArgs + func (p *ImpalaServicePingImpalaServiceArgs) Read(iprot thrift.TProtocol) error + func (p *ImpalaServicePingImpalaServiceArgs) String() string + func (p *ImpalaServicePingImpalaServiceArgs) Write(oprot thrift.TProtocol) error + type ImpalaServicePingImpalaServiceResult struct + func NewImpalaServicePingImpalaServiceResult() *ImpalaServicePingImpalaServiceResult + func (p *ImpalaServicePingImpalaServiceResult) Read(iprot thrift.TProtocol) error + func (p *ImpalaServicePingImpalaServiceResult) String() string + func (p *ImpalaServicePingImpalaServiceResult) Write(oprot thrift.TProtocol) error + type ImpalaServiceProcessor struct + func NewImpalaServiceProcessor(handler ImpalaService) *ImpalaServiceProcessor + type TImpalaQueryOptions int64 + const TImpalaQueryOptions_ABORT_ON_ERROR + const TImpalaQueryOptions_ALLOW_UNSUPPORTED_FORMATS + const TImpalaQueryOptions_BATCH_SIZE + const TImpalaQueryOptions_DEBUG_ACTION + const TImpalaQueryOptions_DEFAULT_ORDER_BY_LIMIT + const TImpalaQueryOptions_DISABLE_CODEGEN + const TImpalaQueryOptions_MAX_ERRORS + const TImpalaQueryOptions_MAX_IO_BUFFERS + const TImpalaQueryOptions_MAX_SCAN_RANGE_LENGTH + const TImpalaQueryOptions_MEM_LIMIT + const TImpalaQueryOptions_NUM_NODES + const TImpalaQueryOptions_NUM_SCANNER_THREADS + func TImpalaQueryOptionsFromString(s string) (TImpalaQueryOptions, error) + func TImpalaQueryOptionsPtr(v TImpalaQueryOptions) *TImpalaQueryOptions + func (p *TImpalaQueryOptions) Scan(value interface{}) error + func (p *TImpalaQueryOptions) UnmarshalText(text []byte) error + func (p *TImpalaQueryOptions) Value() (driver.Value, error) + func (p TImpalaQueryOptions) MarshalText() ([]byte, error) + func (p TImpalaQueryOptions) String() string + type TInsertResult_ struct + RowsAppended map[string]int64 + var ImpalaServiceCloseInsertResult_Success_DEFAULT *TInsertResult_ + func NewTInsertResult_() *TInsertResult_ + func (p *TInsertResult_) GetRowsAppended() map[string]int64 + func (p *TInsertResult_) Read(iprot thrift.TProtocol) error + func (p *TInsertResult_) ReadField1(iprot thrift.TProtocol) error + func (p *TInsertResult_) String() string + func (p *TInsertResult_) Write(oprot thrift.TProtocol) error Incompatible versions in this module v2.0.3+incompatible Dec 25, 2020 v2.0.2+incompatible Dec 24, 2020 v2.0.0+incompatible May 26, 2019
Go to main page