Hadoop
HBase 데이터 Scan 및 Delete
gilnet
2011. 12. 30. 13:19
long rowidScanStart = getTimeMilSec("2009111912", dateFormat);
long rowidScanLast = getTimeMilSec( "2011110112", dateFormat);
HTable hTable = new HTable("LogTraffic");
//데이터를 읽어올 범위를 지정
Scan scan = new Scan(Bytes.toBytes(rowidScanStart), Bytes.toBytes(rowidScanLast));
ResultScanner scanner = hTable.getScanner(scan);
for (Result result : scanner) {
//삭제할 RowKey값을 가져온다
byte [] row = result.getRow();
deleteRow(row) ;
deleteRow(row) ;
}
//데이터를 삭제하는 Method
deleteRow(byte[] row){
}
scanner.close();
hTable.close(); //데이터를 삭제하는 Method
deleteRow(byte[] row){
HTable hTable = new HTable("LogTraffic");
Delete del = new Delete(row);
hTable.delete(del);
hTable.close();
}