6.6 删除多行数据

/**
 * 删除指定表中的多行数据
 *
 * @param tableName
 * @param rows
 */
private static void deleteRows(String tableName, String... rows) throws IOException {
    Table table = conn.getTable(TableName.valueOf(tableName));

    /* 一行一行的删除 */
//        for (String row : rows) {
//
//            Delete d = new Delete(Bytes.toBytes(row));
//            table.delete(d);
//        }
    /*批量删除*/
    List<Delete> ds = new ArrayList<>();
    for (String row : rows) {
        ds.add(new Delete(Bytes.toBytes(row)))
    }
    table.delete(ds);
}
Copyright © 尚硅谷大数据 2019 all right reserved,powered by Gitbook
该文件最后修订时间: 2018-11-20 18:14:19

results matching ""

    No results matching ""