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

impala

package module

Go to main page

Versions in this module

v1

v1.0.0

Feb 15, 2019

Changes in this version

+ type ColumnSchema struct

+ Name string

+ Type string

+ type Connection struct

+ func Connect(host string, port int, options *Options) (*Connection, error)

+ func (c *Connection) Close(ctx context.Context) error

+ func (c *Connection) Query(ctx context.Context, query string) (RowSet, error)

type Options

+ PollIntervalSeconds float64

+ type RowSet interface

+ Err func() error

+ FetchAll func(ctx context.Context) []map[string]interface{}

+ MapScan func(dest map[string]interface{}) error

+ Next func(ctx context.Context) bool

+ Poll func(ctx context.Context) (*Status, error)

+ Scan func(dest ...interface{}) error

+ Schema func(ctx context.Context) []*ColumnSchema

+ Wait func(ctx context.Context) (*Status, error)

+ type Status struct

+ Error error

+ func (s *Status) IsComplete() bool

+ func (s *Status) IsSuccess() bool

v0

v0.0.0

Jun 2, 2023

Changes in this version

+ var DefaultOptions = Options

+ var ErrNotSupported = errors.New("impala: not supported")

+ func NewConnector(opts *Options) driver.Connector

+ type Conn struct

+ func (c *Conn) Begin() (driver.Tx, error)

+ func (c *Conn) CheckNamedValue(val *driver.NamedValue) error

+ func (c *Conn) Close() error

+ func (c *Conn) ExecContext(ctx context.Context, q string, args []driver.NamedValue) (driver.Result, error)

+ func (c *Conn) OpenSession(ctx context.Context) (*hive.Session, error)

+ func (c *Conn) Ping(ctx context.Context) error

+ func (c *Conn) Prepare(query string) (driver.Stmt, error)

+ func (c *Conn) PrepareContext(ctx context.Context, query string) (driver.Stmt, error)

+ func (c *Conn) QueryContext(ctx context.Context, q string, args []driver.NamedValue) (driver.Rows, error)

+ func (c *Conn) ResetSession(ctx context.Context) error

+ type Driver struct

+ func (d *Driver) Open(uri string) (driver.Conn, error)

+ func (d *Driver) OpenConnector(name string) (driver.Connector, error)

+ type Options struct

+ BatchSize int

+ BufferSize int

+ CACertPath string

+ Host string

+ LogOut io.Writer

+ MemoryLimit string

+ Password string

+ Port string

+ QueryTimeout int

+ UseLDAP bool

+ UseTLS bool

+ Username string

+ type Rows struct

+ func (r *Rows) Close() error

+ func (r *Rows) ColumnTypeDatabaseTypeName(index int) string

+ func (r *Rows) ColumnTypeScanType(index int) reflect.Type

+ func (r *Rows) Columns() []string

+ func (r *Rows) Next(dest []driver.Value) error

+ type Stmt struct

+ func (s *Stmt) CheckNamedValue(val *driver.NamedValue) error

+ func (s *Stmt) Close() error

+ func (s *Stmt) Exec(args []driver.Value) (driver.Result, error)

+ func (s *Stmt) ExecContext(ctx context.Context, args []driver.NamedValue) (driver.Result, error)

+ func (s *Stmt) NumInput() int

+ func (s *Stmt) Query(args []driver.Value) (driver.Rows, error)

+ func (s *Stmt) QueryContext(ctx context.Context, args []driver.NamedValue) (driver.Rows, error)

Incompatible versions in this module

v2.1.0+incompatible

Jan 13, 2021

v2.0.0+incompatible

May 26, 2019