home/pinpoint
2
0
Fork 0
mirror of https://github.com/wahyd4/pinpoint.git synced 2026-08-20 18:25:55 +10:00
Code Issues Packages Projects Releases Wiki Activity

[강운덕] [LUCYSUS-1744] hbaseclient의 pool방식과 api 변경.

Browse Source 
git-svn-id: http://svn.bds.nhncorp.com/pe/hippo-commons/trunk@671 84d0f5b1-2673-498c-a247-62c4ff18d310
This commit is contained in:
Woonduk Kang
2012-09-20 03:04:50 +00:00
parent 0b99b33494
commit 3551511b97
4 changed files with 72 additions and 27 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/main/java/com/profiler/common/hbase/HBaseClient.java
+51 -19
View File
@@ -106,16 +106,20 @@ public class HBaseClient {
}
public void close() {
for (String htableName : htableList.keySet()) {
try {
tablePool.closeTablePool(htableName);
} catch (IOException e) {
e.printStackTrace();
}
}
// htableList는 안지워워도 되지.
try {
tablePool.close();
} catch (IOException e) {
// TODO
e.printStackTrace(); //To change body of catch statement use File | Settings | File Templates.
}
}
public Iterator<Map<String, Object>> getHBaseData(HBaseQuery query) {
HTablePool getTablePool() {
return tablePool;
}
public Iterator<Map<String, Object>> getHBaseData(HBaseQuery query) {
ResultSetIterator r = new ResultSetIterator(query);
return r.getIterator();
}
@@ -158,14 +162,14 @@ public class HBaseClient {
}
}
public void flush(byte[] tablename) {
HTable htable = (HTable) tablePool.getTable(tablename);
try {
htable.flushCommits();
} catch (IOException e) {
e.printStackTrace();
}
}
// public void flush(byte[] tablename) {
// HTable htable = (HTable) tablePool.getTable(tablename);
// try {
// htable.flushCommits();
// } catch (IOException e) {
// e.printStackTrace();
// }
// }
public void insert(byte[] tablename, Put put) {
HTable htable = (HTable) tablePool.getTable(tablename);
@@ -173,7 +177,9 @@ public class HBaseClient {
htable.put(put);
} catch (IOException e) {
e.printStackTrace();
}
} finally {
closeHTable(htable);
}
}
public void insert(byte[] tablename, List<Put> put) {
@@ -182,7 +188,9 @@ public class HBaseClient {
htable.put(put);
} catch (IOException e) {
e.printStackTrace();
}
} finally {
closeHTable(htable);
}
}
public void delete(byte[] tablename, Delete delete) {
@@ -191,9 +199,33 @@ public class HBaseClient {
htable.delete(delete);
} catch (IOException e) {
e.printStackTrace();
}
} finally {
closeHTable(htable);
}
}
public void execute(String tableName, HTableCallBack callBack) {
HTable htable = (HTable) tablePool.getTable(tableName);
try {
callBack.doExecute(htable);
} catch (IOException e) {
e.printStackTrace();
// TODO ex 처리
} finally {
closeHTable(htable);
}
}
private void closeHTable(HTable htable) {
if (htable != null) {
try {
htable.close();
} catch (IOException e) {
LOG.warn(e.getMessage(), e);
}
}
}
private class ResultSetIterator {
ResultScanner resultScanner = null;
Iterator<Result> resultIterator;