OracleDataLoader implements RelationalDatabaseLoader { @Override public void loadTable(String tableName, String[] pkColumnNames) { List<Map<String, Object>> rows = query(tableName); HbaseUtil.create(tableName, new String[] { DEFAULT_COLUMN_FAMILY }); HbaseUtil.put(tableName, DEFAULT_COLUMN_FAMILY, rows, pkColumnNames); }  @Override void loadTable(String tableName, String[] pkColumnNames);  }
@Test public void testLoadTable() { String tableName = "report1"; this.loader.loadTable(tableName, new String[] { "TIME_ID", "AREA_ID", "SVC_BRND_ID" }); }