using?Microsoft.Hbase.Client;
using?Microsoft.Hbase.Client.LoadBalancing;
using?org.apache.hadoop.hbase.rest.protobuf.generated;
using?System;
using?System.Collections.Generic;
using?System.Linq;
using?System.Text;
using?System.Threading;

namespace?HbaseRestAPI
{
????class?Program
????{
????????static?void?Main（string[]?args）
????????{?
????????????IHbaseClient?hbaseClient?=?CreateClient（）;
????????????GetVersion（hbaseClient）;
????????????Add（hbaseClient“3““遼寧省鞍山市激光產業園“）;
????????????GetSingle（hbaseClient“1“）;
????????????Delete（hbaseClient?“1“?“author“?1484896798481）;
????????????GetScan（hbaseClient?“1“?“4“）;
????????????Console.Read（）;
????????}
????????///?

????????///?創建對象
????????///?

????????///?
?????????static?IHbaseClient?CreateClient（）
????????{
????????????var?regionServerIPs?=?new?List（）;
????????????//?TODO?automatically?retrieve?IPs?from?Ambari?REST?APIs???
????????????regionServerIPs.Add（“192.168.80.100“）;
????????????var?options?=?RequestOptions.GetDefaultOptions（）;
????????????options.Port?=?8080;
????????????options.AlternativeEndpoint?=?““;
????????????return?new?HbaseClient（null?options?new?LoadBalancerRoundRobin（regionServerIPs））;
????????}
????????///?

????????///?獲取Hbase版本
????????///?

????????///?
????????static?void?GetVersion（IHbaseClient?client）
????????{
????????????//?Retrieve?the?cluster?version
????????????var?version?=?client.GetVersionAsync（）;
????????????version.Wait（）;
????????????Console.WriteLine（“The?Hbase?cluster?version?is?“?+?version.Result.ToString（））;
????????}
????????///?

????????///?不存在添加，存在更新
????????///?

????????///?
????????static?void?Add（IHbaseClient?clientstring?rowKeystring?rowValue）
????????{
?????????????string?testKey?=?rowKey;
?????????????string?testValue?=?rowValue;
????????????var?set?=?new?CellSet（）;
????????????var?row?=?new?CellSet.Row?{?key?=?Encoding.UTF8.GetBytes（testKey）?};
????????????set.rows.Add（row）;
????????????var?value?=?new?Cell?{?column?=?Encoding.UTF8.GetBytes（“author:address“）?data?=?Encoding.UTF8.GetBytes（testValue）?};
????????????row.values.Add（value）;
????????????client.StoreCellsAsync（“blog“?set）.Wait（）;????????
????????}

????????static?void?GetSingle（IHbaseClient?clientstring?rowKey）
????????{???????????
????????????CellSet?cells?=?client.GetCellsAsync（“blog“?rowKey）.Result;
????????????foreach（CellSet.Row?row?in?cells.rows）
????????????{
????????????????Console.WriteLine（“查找行rowKey:{0}“?Encoding.UTF8.GetString（row.key））;
????????????????foreach（Cell?cell?in?row.values）
????????????????{
????????????????????string?column?=?Encoding.UTF8.GetString（cell.column）;
????????????????????string?data=?Encoding.UTF8.GetString（cell.data）;
????????????????????Console.WriteLine（“列名稱:{0}值:{1}“?column?data）;
????????????????}
????????????}
???

?屬性????????????大小?????日期????時間???名稱
-----------?---------??----------?-----??----

????..A..H.????109056??2017-01-23?17:01??HbaseRestAPI\.vs\HbaseRestAPI\v14\.suo

?????文件?????140288??2017-01-23?17:01??HbaseRestAPI\bin\debug\Microsoft.Hbase.Client\Microsoft.Hbase.Client.dll

?????文件???????1907??2017-01-23?17:01??HbaseRestAPI\bin\debug\Microsoft.Hbase.Client\Microsoft.Hbase.Client.dll.CodeAnalysisLog.xml

?????文件??????????0??2017-01-23?17:01??HbaseRestAPI\bin\debug\Microsoft.Hbase.Client\Microsoft.Hbase.Client.dll.lastcodeanalysissucceeded

?????文件?????282112??2017-01-23?17:01??HbaseRestAPI\bin\debug\Microsoft.Hbase.Client\Microsoft.Hbase.Client.pdb

?????文件??????32432??2013-04-25?10:04??HbaseRestAPI\bin\debug\Microsoft.Hbase.Client\Microsoft.Practices.EnterpriseLibrary.TransientFaultHandling.dll

?????文件??????57354??2013-04-25?10:04??HbaseRestAPI\bin\debug\Microsoft.Hbase.Client\Microsoft.Practices.EnterpriseLibrary.TransientFaultHandling.xml

?????文件?????197632??2013-09-30?09:20??HbaseRestAPI\bin\debug\Microsoft.Hbase.Client\protobuf-net.dll

?????文件?????650752??2013-09-30?09:20??HbaseRestAPI\bin\debug\Microsoft.Hbase.Client\protobuf-net.pdb

?????文件?????162411??2013-09-30?09:20??HbaseRestAPI\bin\debug\Microsoft.Hbase.Client\protobuf-net.xml

?????文件????????161??2017-01-23?16:56??HbaseRestAPI\HbaseRestAPI\app.config

?????文件???????7680??2017-01-23?17:01??HbaseRestAPI\HbaseRestAPI\bin\Debug\HbaseRestAPI.exe

?????文件????????161??2017-01-23?16:56??HbaseRestAPI\HbaseRestAPI\bin\Debug\HbaseRestAPI.exe.config

?????文件??????15872??2017-01-23?17:01??HbaseRestAPI\HbaseRestAPI\bin\Debug\HbaseRestAPI.pdb

?????文件??????22688??2017-01-23?17:01??HbaseRestAPI\HbaseRestAPI\bin\Debug\HbaseRestAPI.vshost.exe

?????文件????????161??2017-01-23?16:56??HbaseRestAPI\HbaseRestAPI\bin\Debug\HbaseRestAPI.vshost.exe.config

?????文件????????490??2016-07-16?19:44??HbaseRestAPI\HbaseRestAPI\bin\Debug\HbaseRestAPI.vshost.exe.manifest

?????文件?????140288??2017-01-23?17:01??HbaseRestAPI\HbaseRestAPI\bin\Debug\Microsoft.Hbase.Client.dll

?????文件?????282112??2017-01-23?17:01??HbaseRestAPI\HbaseRestAPI\bin\Debug\Microsoft.Hbase.Client.pdb

?????文件??????32432??2013-04-25?10:04??HbaseRestAPI\HbaseRestAPI\bin\Debug\Microsoft.Practices.EnterpriseLibrary.TransientFaultHandling.dll

?????文件??????57354??2013-04-25?10:04??HbaseRestAPI\HbaseRestAPI\bin\Debug\Microsoft.Practices.EnterpriseLibrary.TransientFaultHandling.xml

?????文件?????197632??2013-09-30?09:20??HbaseRestAPI\HbaseRestAPI\bin\Debug\protobuf-net.dll

?????文件?????650752??2013-09-30?09:20??HbaseRestAPI\HbaseRestAPI\bin\Debug\protobuf-net.pdb

?????文件?????162411??2013-09-30?09:20??HbaseRestAPI\HbaseRestAPI\bin\Debug\protobuf-net.xml

?????文件???????3742??2017-01-23?17:01??HbaseRestAPI\HbaseRestAPI\HbaseRestAPI.csproj

?????文件??????13343??2017-01-23?17:01??HbaseRestAPI\HbaseRestAPI\obj\Debug\DesignTimeResolveAssemblyReferencesInput.cache

?????文件???????1014??2017-01-23?17:01??HbaseRestAPI\HbaseRestAPI\obj\Debug\HbaseRestAPI.csproj.FileListAbsolute.txt

?????文件??????31506??2017-01-23?17:01??HbaseRestAPI\HbaseRestAPI\obj\Debug\HbaseRestAPI.csprojResolveAssemblyReference.cache

?????文件???????7680??2017-01-23?17:01??HbaseRestAPI\HbaseRestAPI\obj\Debug\HbaseRestAPI.exe

?????文件??????15872??2017-01-23?17:01??HbaseRestAPI\HbaseRestAPI\obj\Debug\HbaseRestAPI.pdb

............此處省略187個文件信息