class 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);
    }

}