HbaseThriftPool
HbaseThrift 连接池 //初始化连接池 HBaseClientPool.InitHBaseClientPool("192.168.0.242:9090|192.168.0.246:9090|192.168.0.250:9090"); //使用using 释放连接到连接池 using (var hclient = HBaseClientPool.GetHclient()) { Stopwatch sw = new Stopwatch(); for (int i = 0; i <= 10000; i++) { try { sw.Restart(); string row = System.Guid.NewGuid().ToString(); hclient.Client.mutateRow("1".ToBytes(), row.ToBytes(), new List<Mutation> { new Mutation { Column = "b:abc".ToBytes(), Value = DateTime.Now.ToBytes() } }, null); sw.Stop(); Console.WriteLine($"时间：{DateTime.Now} 耗时：{sw.ElapsedMilliseconds} "); } catch (Exception ex) { Console.WriteLine(ex.Message); } } }
Activity
- Latest release
- 8y ago
- Total releases
- 2
- Cadence
- ~16 days
- Last 12 months
- 0
Details
- First release
- Jun 20, 2018
| Version | Released | |
|---|---|---|
1.1.2.1
patch
|
1.1.2.1
patch
Dependencies (2)
|
|
1.1.2
initial
|
1.1.2
initial
Dependencies (2)
|