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();