baichongyang baca853c99 first init		3 年之前
..
filter	baca853c99 first init	3 年之前
hrpc	baca853c99 first init	3 年之前
pb	baca853c99 first init	3 年之前
region	baca853c99 first init	3 年之前
zk	baca853c99 first init	3 年之前
.travis.yml	baca853c99 first init	3 年之前
AUTHORS	baca853c99 first init	3 年之前
COPYING	baca853c99 first init	3 年之前
Makefile	baca853c99 first init	3 年之前
README.md	baca853c99 first init	3 年之前
admin_client.go	baca853c99 first init	3 年之前
caches.go	baca853c99 first init	3 年之前
check_line_len.awk	baca853c99 first init	3 年之前
client.go	baca853c99 first init	3 年之前
go.mod	baca853c99 first init	3 年之前
go.sum	baca853c99 first init	3 年之前
rpc.go	baca853c99 first init	3 年之前
scanner.go	baca853c99 first init	3 年之前

Golang HBase client

This is a pure Go client for HBase.

Current status: beta.

Supported Versions

HBase >= 1.0

Installation

go get github.com/tsuna/gohbase

Example Usage

Create a client

client := gohbase.NewClient("localhost")

Insert a cell

// Values maps a ColumnFamily -> Qualifiers -> Values.
values := map[string]map[string][]byte{"cf": map[string][]byte{"a": []byte{0}}}
putRequest, err := hrpc.NewPutStr(context.Background(), "table", "key", values)
rsp, err := client.Put(putRequest)

Get an entire row

getRequest, err := hrpc.NewGetStr(context.Background(), "table", "row")
getRsp, err := client.Get(getRequest)

Get a specific cell

// Perform a get for the cell with key "15", column family "cf" and qualifier "a"
family := map[string][]string{"cf": []string{"a"}}
getRequest, err := hrpc.NewGetStr(context.Background(), "table", "15",
    hrpc.Families(family))
getRsp, err := client.Get(getRequest)

Get a specific cell with a filter

pFilter := filter.NewKeyOnlyFilter(true)
family := map[string][]string{"cf": []string{"a"}}
getRequest, err := hrpc.NewGetStr(context.Background(), "table", "15",
    hrpc.Families(family), hrpc.Filters(pFilter))
getRsp, err := client.Get(getRequest)

Scan with a filter

pFilter := filter.NewPrefixFilter([]byte("7"))
scanRequest, err := hrpc.NewScanStr(context.Background(), "table",
		hrpc.Filters(pFilter))
scanRsp, err := client.Scan(scanRequest)

Contributing

Any help would be appreciated. Please use Github pull requests to send changes for review. Please sign the Contributor License Agreement when you send your first change for review.

README.md