rowkey查詢

//根據(jù)rowKey進(jìn)行查詢public static User getDataByRowKey(String tableName, String rowKey,String password) throws IOException {Admin admin = connection.getAdmin();Table table = connection.getTable(TableName.valueOf(tableName));Get get = new Get(rowKey.getBytes());User user = new User();user.setName(rowKey);//先判斷是否有此條數(shù)據(jù)if(!get.isCheckExistenceOnly()){Result result = table.get(get);Cell[] cells = result.rawCells();for ( Cell cell : cells){String colName = Bytes.toString(cell.getQualifierArray(), cell.getQualifierOffset(), cell.getQualifierLength());String value = Bytes.toString(cell.getValueArray(), cell.getValueOffset(), cell.getValueLength());System.out.println(" ========= "+colName);System.out.println("=========" + value);if(colName.equals("pwd")){user.setPwd(value);}if (colName.equals("email")){user.setEmail(value);}}}return user;}

總結(jié)

以上是生活随笔為你收集整理的Java操作HBase的全部?jī)?nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。