Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

gohive

package module

Go to main page

Versions in this module

v1

v1.1.2

May 19, 2020

Changes in this version

type Connection

+ func (c *Connection) MetaData() *DatabaseMetaData

+ type DatabaseMetaData struct

+ func (md *DatabaseMetaData) GetColumns(ctx context.Context, catalog string, schemaPattern string, ...) (cursor *Cursor)

+ func (md *DatabaseMetaData) GetSchemas(ctx context.Context) (cursor *Cursor)

+ func (md *DatabaseMetaData) GetTables(ctx context.Context, catalog string, schemaPattern string, ...) (cursor *Cursor)

v1.1.1

May 18, 2020

Changes in this version

type Cursor

+ OperationHandle *hiveserver.TOperationHandle

v1.1.0

May 13, 2020

Changes in this version

type Connection

+ SessionHandle *hiveserver.TSessionHandle

v1.0.7

May 4, 2020

Changes in this version

type Connection

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

v1.0.6

Apr 3, 2020

v1.0.5

Apr 3, 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

+ FetchSize int64

+ HTTPPath string

+ HiveConfiguration map[string]string

+ Password string

+ PollIntervalInMillis int

+ Principal string

+ Service string

+ TLSConfig *tls.Config

+ TransportMode string

+ UseZookeeper bool

+ 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 (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)