hive2

README

thrift -gen go:package_prefix=github.com/mumuhhh/gohive2/hive/rpc/ -out rpc ./TCLService.thrift

Documentation

Index

• Constants
• Variables
• type ConnParams
  • func ParseUrl(uri string) (*ConnParams, error)
• type HiveDriver
  • func (h HiveDriver) Open(uri string) (driver.Conn, error)
  • func (h HiveDriver) OpenConnector(uri string) (driver.Connector, error)
• type TSaslClientTransport
  • func NewTSaslClientTransport(tp thrift.TTransport, saslClient sasl.Client) *TSaslClientTransport
  • func (t *TSaslClientTransport) Close() error
  • func (t *TSaslClientTransport) Flush(ctx context.Context) (err error)
  • func (t *TSaslClientTransport) IsOpen() bool
  • func (t *TSaslClientTransport) Open() (err error)
  • func (t *TSaslClientTransport) Read(p []byte) (n int, err error)
  • func (t *TSaslClientTransport) ReadFrame() error
  • func (t *TSaslClientTransport) RemainingBytes() (numBytes uint64)
  • func (t *TSaslClientTransport) Write(p []byte) (n int, err error)

Constants

const (
	START    byte = 1
	OK       byte = 2
	BAD      byte = 3
	ERROR    byte = 4
	COMPLETE byte = 5
)

const Kerberos = 1

Variables

var MASK = []byte{0x01, 0x02, 0x04, 0x08, 0x10, 0x20, 0x40, 0x80}

Types

type ConnParams

type ConnParams struct {
	DBName        string
	JdbcUriString string
	Addresses     []string
	HiveConf      map[string]string
	HiveVar       map[string]string
	SessionVar    map[string]string
}

func ParseUrl

func ParseUrl(uri string) (*ConnParams, error)

type HiveDriver

type HiveDriver struct{}

func (HiveDriver) Open

func (h HiveDriver) Open(uri string) (driver.Conn, error)

func (HiveDriver) OpenConnector

func (h HiveDriver) OpenConnector(uri string) (driver.Connector, error)

type TSaslClientTransport

type TSaslClientTransport struct {
	// contains filtered or unexported fields
}

func NewTSaslClientTransport

func NewTSaslClientTransport(tp thrift.TTransport, saslClient sasl.Client) *TSaslClientTransport

func (*TSaslClientTransport) Close

func (t *TSaslClientTransport) Close() error

func (*TSaslClientTransport) Flush

func (t *TSaslClientTransport) Flush(ctx context.Context) (err error)

func (*TSaslClientTransport) IsOpen

func (t *TSaslClientTransport) IsOpen() bool

func (*TSaslClientTransport) Open

func (t *TSaslClientTransport) Open() (err error)

func (*TSaslClientTransport) Read

func (t *TSaslClientTransport) Read(p []byte) (n int, err error)

func (*TSaslClientTransport) ReadFrame

func (t *TSaslClientTransport) ReadFrame() error

ReadFrame reads a frame of data into local buffer, which means first read data's length, then reads actual data.

func (*TSaslClientTransport) RemainingBytes

func (t *TSaslClientTransport) RemainingBytes() (numBytes uint64)

func (*TSaslClientTransport) Write

func (t *TSaslClientTransport) Write(p []byte) (n int, err error)