Documentation ¶
Index ¶
- Variables
- type Connection
- func (c *Connection) Close() error
- func (c *Connection) CloseInsert(ctx context.Context, handle *beeswax.QueryHandle) (map[string]int64, error)
- func (c *Connection) CloseQuery(ctx context.Context, handle *beeswax.QueryHandle) error
- func (c *Connection) ExecuteAndWait(ctx context.Context, query string) (RowSet, error)
- func (c *Connection) Query(ctx context.Context, query string) (RowSet, error)
- type Options
- type RowSet
- type Status
Constants ¶
This section is empty.
Variables ¶
View Source
var (
DefaultOptions = Options{PollIntervalSeconds: 0.1, BatchSize: 10000}
)
Functions ¶
This section is empty.
Types ¶
type Connection ¶
type Connection struct { Host string Port int Timeout time.Duration // contains filtered or unexported fields }
func (*Connection) Close ¶
func (c *Connection) Close() error
func (*Connection) CloseInsert ¶
func (c *Connection) CloseInsert(ctx context.Context, handle *beeswax.QueryHandle) (map[string]int64, error)
func (*Connection) CloseQuery ¶
func (c *Connection) CloseQuery(ctx context.Context, handle *beeswax.QueryHandle) error
func (*Connection) ExecuteAndWait ¶
type RowSet ¶
type RowSet interface { Columns() []string Next() bool Scan(dest ...interface{}) error GetRow() ([]string, error) Poll() (*Status, error) Wait() (*Status, error) FetchAll() []map[string]interface{} MapScan(dest map[string]interface{}) error Handle() *beeswax.QueryHandle Cancel() error }
A RowSet represents an asyncronous hive operation. You can Reattach to a previously submitted hive operation if you have a valid thrift client, and the serialized Handle() from the prior operation.
Click to show internal directories.
Click to hide internal directories.