README
¶
go-hbase
UNMAINTAINED: See tsuna's implementation https://github.com/tsuna/gohbase
Implements a fully native HBase client for the Go programming language.
API Documentation: http://godoc.org/github.com/Lazyshot/go-hbase
Supported Versions
HBase >= 0.96.0
This version of HBase has a backwards incompatible change, which takes full use of protocol buffers for client interactions.
Installation
go get github.com/lazyshot/go-hbase
Example
package main
import (
"github.com/lazyshot/go-hbase"
"fmt"
"log"
)
func main() {
client := hbase.NewClient([]string{"localhost"}, "/hbase")
put := hbase.CreateNewPut([]byte("test1"))
put.AddStringValue("info", "test_qual", "test_val")
res, err := client.Put("test", put)
if err != nil {
panic(err)
}
if !res {
panic("No put results")
}
log.Println("Completed put")
get := hbase.CreateNewGet([]byte("test1"))
result, err := client.Get("test", get)
if err != nil {
panic(err)
}
if !bytes.Equal(result.Row, []byte("test1")) {
panic("No row")
}
if !bytes.Equal(result.Columns["info:test_qual"].Value, []byte("test_val")) {
panic("Value doesn't match")
}
log.Println("Completed get")
results, err := client.Gets("test", []*hbase.Get{get})
if err != nil {
panic(err)
}
log.Printf("%#v", results)
}
License
Copyright (c) 2014-2015 Bryan Peterson. All rights reserved. Use of this source code is governed by a BSD-style license that can be found in the LICENSE file.
Documentation
¶
Index ¶
- type Client
- func (c *Client) AsyncGets(table string, results chan *ResultRow, gets []*Get)
- func (c *Client) Delete(table string, del *Delete) (bool, error)
- func (c *Client) Deletes(table string, dels []*Delete) (bool, error)
- func (c *Client) Get(table string, get *Get) (*ResultRow, error)
- func (c *Client) GetTables() []TableInfo
- func (c *Client) Gets(table string, gets []*Get) ([]*ResultRow, error)
- func (c *Client) Put(table string, put *Put) (bool, error)
- func (c *Client) Puts(table string, puts []*Put) (bool, error)
- func (c *Client) Scan(table string) *Scan
- func (c *Client) SetLogLevel(level string)
- type Delete
- type EncodedValue
- type Get
- type Put
- type ResultRow
- type ResultRowColumn
- type Scan
- func (s *Scan) AddColumn(family, qual []byte)
- func (s *Scan) AddFamily(family []byte)
- func (s *Scan) AddString(famqual string) error
- func (s *Scan) AddStringColumn(family, qual string)
- func (s *Scan) AddStringFamily(family string)
- func (s *Scan) Close()
- func (s *Scan) Map(f func(*ResultRow))
- func (s *Scan) SetCached(n int)
- func (s *Scan) SetTimeRange(from time.Time, to time.Time)
- func (s *Scan) SetTimeRangeFrom(from time.Time)
- func (s *Scan) SetTimeRangeTo(to time.Time)
- type TableInfo
- type TimeRange
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Client ¶
type Client struct {
// contains filtered or unexported fields
}
func (*Client) SetLogLevel ¶
type Delete ¶
type Delete struct {
// contains filtered or unexported fields
}
func CreateNewDelete ¶
func (*Delete) AddStringColumn ¶
func (*Delete) AddStringFamily ¶
type EncodedValue ¶
type EncodedValue []byte
func (EncodedValue) String ¶
func (e EncodedValue) String() string
type Get ¶
type Get struct {
// contains filtered or unexported fields
}
func CreateNewGet ¶
func (*Get) AddStringColumn ¶
func (*Get) AddStringFamily ¶
type Put ¶
type Put struct {
// contains filtered or unexported fields
}
func CreateNewPut ¶
func (*Put) AddStringValue ¶
func (*Put) AddStringValueTS ¶
AddStringValueTS use user specified timestamp
func (*Put) AddValueTS ¶
AddValueTS use user specified timestamp
type ResultRow ¶
type ResultRow struct {
Row EncodedValue
Columns map[string]*ResultRowColumn
SortedColumns []*ResultRowColumn
}
type ResultRowColumn ¶
type ResultRowColumn struct {
ColumnName string
Family EncodedValue
Qualifier EncodedValue
Timestamp time.Time
Value EncodedValue
Values map[time.Time]EncodedValue
}
type Scan ¶
func (*Scan) AddStringColumn ¶
func (*Scan) AddStringFamily ¶
func (*Scan) SetTimeRange ¶
set scan time range
func (*Scan) SetTimeRangeFrom ¶
set scan time start only. if set start only, use a max timestamp as end automaticly. but since max timestamp is not a precise value, you'd better use `SetTimeRange()` set start and end yourself.
func (*Scan) SetTimeRangeTo ¶
set scan time end only. if only set end, use time.Unix(0, 0)(Jan 1st, 1970) as start automaticly
Source Files
Directories