From 727f43543fda56ba20e2722c04cf4b87dcc934ec Mon Sep 17 00:00:00 2001 From: Woonduk Kang Date: Thu, 20 Sep 2012 03:51:23 +0000 Subject: [PATCH] =?UTF-8?q?[=EA=B0=95=EC=9A=B4=EB=8D=95]=20[LUCYSUS-1744]?= =?UTF-8?q?=20api=20=EC=9D=B8=EC=9E=90=20=EB=B3=80=EA=B2=BD.?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit git-svn-id: http://svn.bds.nhncorp.com/pe/hippo-commons/trunk@672 84d0f5b1-2673-498c-a247-62c4ff18d310 --- .../com/profiler/common/hbase/HBaseClient.java | 14 +++----------- .../com/profiler/common/hbase/HBaseClientTest.java | 2 +- 2 files changed, 4 insertions(+), 12 deletions(-) diff --git a/src/main/java/com/profiler/common/hbase/HBaseClient.java b/src/main/java/com/profiler/common/hbase/HBaseClient.java index 0873696c8..e9b626823 100644 --- a/src/main/java/com/profiler/common/hbase/HBaseClient.java +++ b/src/main/java/com/profiler/common/hbase/HBaseClient.java @@ -162,16 +162,8 @@ public class HBaseClient { } } -// 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) { + public void insert(String tablename, Put put) { HTable htable = (HTable) tablePool.getTable(tablename); try { htable.put(put); @@ -182,7 +174,7 @@ public class HBaseClient { } } - public void insert(byte[] tablename, List put) { + public void insert(String tablename, List put) { HTable htable = (HTable) tablePool.getTable(tablename); try { htable.put(put); @@ -193,7 +185,7 @@ public class HBaseClient { } } - public void delete(byte[] tablename, Delete delete) { + public void delete(String tablename, Delete delete) { HTable htable = (HTable) tablePool.getTable(tablename); try { htable.delete(delete); diff --git a/src/test/java/com/profiler/common/hbase/HBaseClientTest.java b/src/test/java/com/profiler/common/hbase/HBaseClientTest.java index 6aba1aa97..098158600 100644 --- a/src/test/java/com/profiler/common/hbase/HBaseClientTest.java +++ b/src/test/java/com/profiler/common/hbase/HBaseClientTest.java @@ -68,7 +68,7 @@ public class HBaseClientTest { put.add(Bytes.toBytes(COLUMN_FAMILY), Bytes.toBytes("qual2"), Bytes.toBytes("val2")); putList.add(put); } - client.insert(Bytes.toBytes(TABLE_NAME), putList); + client.insert(TABLE_NAME, putList); List list = new ArrayList();