Versions in this module Expand all Collapse all v1 v1.0.4 Dec 14, 2023 v1.0.3 Dec 14, 2023 v1.0.2 Sep 8, 2022 Changes in this version + const BAD + const COMPLETE + const DEFAULT_FETCH_SIZE + const DEFAULT_MAX_LENGTH + const ERROR + const OK + const START + const ZOOKEEPER_DEFAULT_NAMESPACE + var DEFAULT_ERROR_CODE = int32(-1) + var DEFAULT_ERROR_MESSAGE = "unknown error" + var DEFAULT_SQL_STATE = "" + var DEFAULT_STATUS = hiveserver.TStatus + type ConnectConfiguration struct + ConnectTimeout time.Duration + Database string + DialContext DialContextFunc + DisableKeepAlives bool + FetchSize int64 + HTTPPath string + HiveConfiguration map[string]string + HttpTimeout time.Duration + MaxSize uint32 + Password string + PollIntervalInMillis int + Principal string + Service string + SocketTimeout time.Duration + TLSConfig *tls.Config + TransportMode string + Username string + ZookeeperNamespace string + func NewConnectConfiguration() *ConnectConfiguration + type Connection struct + func Connect(host string, port int, auth string, configuration *ConnectConfiguration) (conn *Connection, err error) + func ConnectZookeeper(hosts string, auth string, configuration *ConnectConfiguration) (conn *Connection, err error) + func (c *Connection) Close() error + func (c *Connection) Cursor() *Cursor + type Cursor struct + Err error + Logs chan<- []string + func (c *Cursor) Cancel() + func (c *Cursor) Close() + func (c *Cursor) Description() [][]string + func (c *Cursor) Error() error + func (c *Cursor) Exec(ctx context.Context, query string) + func (c *Cursor) Execute(ctx context.Context, query string, async bool) + func (c *Cursor) FetchLogs() []string + func (c *Cursor) FetchOne(ctx context.Context, dests ...interface{}) + func (c *Cursor) Finished() bool + func (c *Cursor) HasMore(ctx context.Context) bool + func (c *Cursor) Poll(getProgress bool) (status *hiveserver.TGetOperationStatusResp) + func (c *Cursor) RowMap(ctx context.Context) map[string]interface{} + func (c *Cursor) WaitForCompletion(ctx context.Context) + type DialContextFunc func(ctx context.Context, network, addr string) (net.Conn, error) + type HiveError struct + ErrorCode int + Message string + type TSaslTransport struct + OpeningContext context.Context + func NewTSaslTransport(trans thrift.TTransport, host string, mechanismName string, ...) (*TSaslTransport, error) + func (p *TSaslTransport) Close() (err error) + func (p *TSaslTransport) Flush(ctx context.Context) (err error) + func (p *TSaslTransport) IsOpen() bool + func (p *TSaslTransport) Open() (err error) + func (p *TSaslTransport) Read(buf []byte) (l int, err error) + func (p *TSaslTransport) RemainingBytes() uint64 + func (p *TSaslTransport) SetMaxLength(maxLength uint32) + func (p *TSaslTransport) Write(buf []byte) (int, error)
Go to main page