package oracle.demo.oow.bd.util.hbase;
import org.apache.hadoop.conf.configuration;
import org.apache.hadoop.hbase.hbaseconfiguration;
import org.apache.hadoop.hbase.client.connection;
import org.apache.hadoop.hbase.client.connectionfactory;
public class hbaseconn
private hbaseconn() catch (exception e)
}public static final connection getconn()
public static void main(string args)
}public long incr(string tablename, string rowkey, string family, string column, long range) catch (ioexception e)
return count;}
（2）插入或修改一條資料，針對列族中的一列 long型 其他型別也可以 修改雷清即可
public void put(string tablename, string rowkey, string family, string column, long value) catch (ioexception e) }
（3）查詢資料 根據行鍵查詢 這裡舉例 行鍵為long型
public result getresultbyrow(string tablename, long rowkey, string family)
result = table.get(get);
table.close();
} catch (ioexception e)
return result;
}返回值是乙個result，get方法 可以新增列族 行鍵
（4）掃瞄表 使用scan方法
public resultscanner getresultscannerbyfilter(string tablename, filter filter, string family)
if(family != null)
resultscanner = table.getscanner(scan);
table.close();
} catch (ioexception e)
return resultscanner;
}返回值是乙個resultscanner，我們可以闖入乙個過濾器來進行掃瞄。
（5）刪除資料
public void deletedatabyrow(string tablename, string rowkey) catch (ioexception e) }
Java API的中度使用
locksupport，park unpark 日誌表的設計 我現在入職一家新公司，在設計表的結構和整個專案邏輯，好了，乙個乙個說，我安裝了svn伺服器和tomcat伺服器，配置了一下許可權，首先是區域網內走通。然後是通過專案邏輯，來設計表，表就不好在這寫了，反正就那些東西，大家懂的。然後就是乙個同...
大資料開發之scala操作hbase的工具類
org.apache.hbase hbase client 1.2.1 org.apache.hbase hbase common 1.2.1 注意 匯入依賴的版本號要與集群的hbase版本號一致 否則會不相容報錯從hbase集群的conf資料夾將hbase site.xml拷貝到工程的resour...
Zookeeper之javaAPI的使用
主要jar包在主目錄下 專案需要的相關依賴的jar包在zookeeper的解壓檔案的lib目錄下就有 將這幾個jar包匯入專案中 zookeeper的伺服器位址,配置conf是用主機名，這裡一樣 private string connectstring zek00 2181,zek01 2181,z...