Versions in this module Expand all Collapse all v1 v1.2.3 Oct 7, 2021 v1.2.2 Nov 5, 2020 Changes in this version type ConnectConfiguration + FrameMaxLength string v1.2.1 Nov 5, 2020 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 + type ConnectConfiguration struct + Database string + FetchSize int64 + HTTPPath string + HiveConfiguration map[string]string + Password string + PollIntervalInMillis int + Principal string + Service string + 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 + 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) FetchOne(ctx context.Context, dests ...interface{}) + func (c *Cursor) Finished() bool + func (c *Cursor) HasMore(ctx context.Context) bool + func (c *Cursor) Poll(getProgres bool) (status *hiveserver.TGetOperationStatusResp) + func (c *Cursor) RowMap(ctx context.Context) map[string]interface{} + func (c *Cursor) WaitForCompletion(ctx context.Context) + 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