У меня есть следующие строки с этими ключами в таблице hbase "mytable"
user_1
user_2
user_3
...
user_9999999
Я хочу использовать оболочку Hbase для удаления строк из:
user_500 пользователю_900
Я знаю, что нет способа удалить, но есть ли способ использовать "BulkDeleteProcessor" для этого?
Я вижу здесь:
Я хочу просто вставить импорт, а затем вставить его в оболочку, но не знаю, как это сделать. Кто-нибудь знает, как я могу использовать эту конечную точку из оболочки jruby hbase?
Table ht = TEST_UTIL.getConnection().getTable("my_table");
long noOfDeletedRows = 0L;
Batch.Call<BulkDeleteService, BulkDeleteResponse> callable =
new Batch.Call<BulkDeleteService, BulkDeleteResponse>() {
ServerRpcController controller = new ServerRpcController();
BlockingRpcCallback<BulkDeleteResponse> rpcCallback =
new BlockingRpcCallback<BulkDeleteResponse>();
public BulkDeleteResponse call(BulkDeleteService service) throws IOException {
Builder builder = BulkDeleteRequest.newBuilder();
builder.setScan(ProtobufUtil.toScan(scan));
builder.setDeleteType(deleteType);
builder.setRowBatchSize(rowBatchSize);
if (timeStamp != null) {
builder.setTimestamp(timeStamp);
}
service.delete(controller, builder.build(), rpcCallback);
return rpcCallback.get();
}
};
Map<byte[], BulkDeleteResponse> result = ht.coprocessorService(BulkDeleteService.class, scan
.getStartRow(), scan.getStopRow(), callable);
for (BulkDeleteResponse response : result.values()) {
noOfDeletedRows += response.getRowsDeleted();
}
ht.close();
Если не существует способа сделать это через JRuby, Java или альтернативный способ быстрого удаления нескольких строк в порядке.