x1ongzhu 4750177287 first commit 6 anos atrás
..
filter 4750177287 first commit 6 anos atrás
hrpc 4750177287 first commit 6 anos atrás
pb 4750177287 first commit 6 anos atrás
region 4750177287 first commit 6 anos atrás
zk 4750177287 first commit 6 anos atrás
AUTHORS 4750177287 first commit 6 anos atrás
BUILD.bazel 4750177287 first commit 6 anos atrás
COPYING 4750177287 first commit 6 anos atrás
Makefile 4750177287 first commit 6 anos atrás
README.md 4750177287 first commit 6 anos atrás
admin_client.go 4750177287 first commit 6 anos atrás
caches.go 4750177287 first commit 6 anos atrás
check_line_len.awk 4750177287 first commit 6 anos atrás
client.go 4750177287 first commit 6 anos atrás
install_ci.sh 4750177287 first commit 6 anos atrás
rpc.go 4750177287 first commit 6 anos atrás
scanner.go 4750177287 first commit 6 anos atrás

README.md

Golang HBase client Build Status codecov.io GoDoc

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.

License

Copyright © 2015 The GoHBase Authors. All rights reserved. Use of this source code is governed by the Apache License 2.0 that can be found in the COPYING file.