myhbase

Documentation

Overview

Copyright 2017 by GoSpider author. Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at

http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.

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"