gohive

Dec 23, 2023

Changes in this version

+ type HiveMetastoreClient struct

+ Client *hive_metastore.ThriftHiveMetastoreClient

+ func ConnectToMetastore(host string, port int, auth string, ...) (client *HiveMetastoreClient, err error)

+ func (c *HiveMetastoreClient) Close()

+ type MetastoreConnectConfiguration struct

+ Password string

+ TransportMode string

+ Username string

+ func NewMetastoreConnectConfiguration() *MetastoreConnectConfiguration

Jan 14, 2023

Changes in this version

type ConnectConfiguration

+ DisableKeepAlives bool

+ MaxSize uint32

Mar 11, 2022

Changes in this version

type ConnectConfiguration

+ ConnectTimeout time.Duration

+ DialContext DialContextFunc

+ HttpTimeout time.Duration

+ SocketTimeout time.Duration

+ type DialContextFunc func(ctx context.Context, network, addr string) (net.Conn, error)

Oct 9, 2021

Changes in this version

+ var DEFAULT_ERROR_CODE = int32(-1)

+ var DEFAULT_ERROR_MESSAGE = "unknown error"

+ var DEFAULT_SQL_STATE = ""

+ var DEFAULT_STATUS = hiveserver.TStatus

type HiveError

+ Message string

Jul 15, 2021

Changes in this version

type Cursor

+ Logs chan<- []string

+ type HiveError struct

+ ErrorCode int

Feb 27, 2021

Changes in this version

type Cursor

+ func (c *Cursor) FetchLogs() []string

Jul 12, 2020

Changes in this version

type ConnectConfiguration

+ Database string

Apr 26, 2020

Changes in this version

+ const ZOOKEEPER_DEFAULT_NAMESPACE

type ConnectConfiguration

+ ZookeeperNamespace string

type Connection

+ func ConnectZookeeper(hosts string, auth string, configuration *ConnectConfiguration) (conn *Connection, err error)

Dec 7, 2019

Changes in this version

type TSaslTransport

+ func (p *TSaslTransport) SetMaxLength(maxLength uint32)

Sep 1, 2019

Changes in this version

+ const BAD

+ const COMPLETE

+ const DEFAULT_FETCH_SIZE

+ const DEFAULT_MAX_LENGTH

+ const ERROR

+ const OK

+ const START

+ type ConnectConfiguration struct

+ FetchSize int64

+ HTTPPath string

+ HiveConfiguration map[string]string

+ Password string

+ PollIntervalInMillis int

+ Principal string

+ Service string

+ TLSConfig *tls.Config

+ TransportMode string

+ Username string

+ func NewConnectConfiguration() *ConnectConfiguration

+ type Connection struct

+ func Connect(host string, port int, 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) Write(buf []byte) (int, error)