gohbase
gohbase copied to clipboard
tsuna
Pure-Go HBase client
Is it possible to support configurable scanner timeout and client RPC timeouts? These would be equivalent to hbase.client.scanner.timeout.period and hbase.rpc.timeout respectively in the in Java HBase client. This would allow...
hello I use hbase scan filter code: bytes := []byte("54.36.149.65") comparable := filter.NewByteArrayComparable(bytes) fc := filter.NewBinaryComparator(comparable) CompareOp := 0 f := filter.NewCompareFilter(filter.CompareType(CompareOp), fc) str, err := hrpc.NewScanStr(context.Background(), "hub:ip_parse_init", hrpc.Filters(f)) if...
after RegionServerStoppedException，goroutine which reads data from the dead region will be blocked
 there has RegionServerStoppedException with one dead node. And goroutine will be blocked when reads data from the dead node. how to return error instead of blocked?
If region server down for some time, and then comes back later. The client would not recreate a new connection but keep block sending in isRegionEstablished.
In our production environment, when a table contains a large quantity of regions (more than 1000 regions), the client will send too many scan requests to meta regionserver when the...
If there are a lot of RPC request to a same table, but the region information not in cache. ```go func (c *client) findRegion(ctx context.Context, table, key []byte) (hrpc.RegionInfo, error)...
Currently we can only pass [ColumnFamilySchema attributes](https://github.com/tsuna/gohbase/blob/master/pb/HBase.proto#L54) in `CreateTable`. Need to be able to specify [TableShema attributes](https://github.com/tsuna/gohbase/blob/master/pb/HBase.proto#L43)
Is it possible to create a put with tag? like https://hbase.apache.org/1.1/apidocs/org/apache/hadoop/hbase/client/Put.html#addImmutable(byte[],%20byte[],%20long,%20byte[],%20org.apache.hadoop.hbase.Tag[])
