版权声明：本文为博主原创文章，未经博主允许不得转载。 https://blog.csdn.net/jin6872115/article/details/86098271
Hbase没有删除某列数据的直接命令，通过指定表名，列簇，列名
package com.cslc.asiancup.dfstohbase;
import com.cslc.asiancup.utils.HbaseUtil;
import com.cslc.asiancup.utils.HbaseUtilJava;
import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.hbase.TableName;
import org.apache.hadoop.hbase.client.*;
import scala.Option;
import java.io.IOException;
import java.util.ArrayList;
import java.util.Iterator;
/**
* @Author :LPJ
* @Date 2019/1/4 12:31
*/
public class DROP_Cloumn {
public static void main(String[] args) throws IOException {
final Configuration conf = HbaseUtilJava.conf;
Connection connection = ConnectionFactory.createConnection(conf);
Table table = connection.getTable(TableName.valueOf("UNNORMAL_STATUS"));
final Scan scan = new Scan();
scan.addColumn("CF1".getBytes(),"LOTTERY_AMOUNT".getBytes());
final Iterator<Result> iterator = table.getScanner(scan).iterator();
for( int i =0; i < 50 ; i ++){
final ArrayList<Delete> deletes = new ArrayList<Delete>();
while (iterator.hasNext() && deletes.size() <= 100000) {
final Result v = iterator.next();
final Delete delete = new Delete(v.getRow());
if (v.containsColumn("CF1".getBytes(), "LOTTERY_AMOUNT".getBytes())) {
delete.deleteColumns("CF1".getBytes(), "LOTTERY_AMOUNT".getBytes());
deletes.add(delete);
}
}
table.delete(deletes);
}
table.close();
connection.close();
}
}