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