myhbase

Documentation

Index

• type Hbase
  • func New(config HbaseConfig) Hbase
  • func (db *Hbase) GetResult(table string, rowkey string) (result *hbase.ResultRow, err error)
  • func (db *Hbase) Open()
• type HbaseConfig

Types

type Hbase

type Hbase struct {
	Config HbaseConfig
	Client *hbase.Client
}

a hbase client

func New

func New(config HbaseConfig) Hbase

create a new hbase client

func (*Hbase) GetResult

func (db *Hbase) GetResult(table string, rowkey string) (result *hbase.ResultRow, err error)

获取结果 Get a result by hbase rowkey

func (*Hbase) Open

func (db *Hbase) Open()

太坑了，坑啊，表名前缀不能太相似！！such as aaaaaaaaaaaaaaaaa,aaaaaaaaaaaaaaaaaab这样可能会把数据发送到另外的表 init hbase connection,the table name can't be have a long same prefix

type HbaseConfig

type HbaseConfig struct {
	//zookeeper port
	Zkport string
	//zk ip
	Zkquorum string
}

hbase配置结构体,modify by java a hbase config

"master": "192.168.11.73:60000",
"zkport": "2181",
"zkquorum": "192.168.11.73,192.168.11.74"