Accumulo удалить строку с меткой безопасности - PullRequest
Новая
       54

Accumulo удалить строку с меткой безопасности

0 голосов
/ 08 мая 2018

Я пытаюсь удалить строку Accumulo в таблице. Таблица выглядит так: 

Key: id0001 hero:alias [secretId] 1525804166026 false             Value: Batman
Key: id0001 hero:name [secretId] 1525804166026 false              Value: Bruce Wayne
Key: id0001 hero:wearsCape? [secretId] 1525804166026 false        Value: true
Key: id0002 hero:alias [] 1525804166026 false                     Value: Robin
Key: id0002 hero:name [secretId] 1525804166026 false              Value: Dick Grayson
Key: id0002 hero:wearsCape? [secretId] 1525804166026 false        Value: true
Key: id0003 hero:alias [] 1525804166026 false                     Value: Joker
Key: id0003 hero:name [] 1525804166026 false                      Value: Unknown
Key: id0003 hero:wearsCape? [] 1525804166026 false                Value: false

Я пытаюсь удалить строку с идентификатором "id0001", ColFam "hero", ColQual "name". Мой код такой: 

    Mutation mut = new Mutation("id0001");
    mut.putDelete(new Text("hero"), new Text("name"));
    try (Scanner scanner1 = commishConn.createScanner("GothamPD", new Authorizations("secretId"))) {
      //scanner1.setRange(Range.exact("id0001"));
      for (Entry<Key,Value> entry : scanner1) {
        mut.putDelete(entry.getKey().getColumnFamily(), entry.getKey().getColumnQualifier());
      }
    }
    BatchWriter batchwriter = conn.createBatchWriter("GothamPD",1000000, 60000, 2);
    batchwriter.addMutation(mut);
    batchwriter.flush();

Не удаляется, хотя я указал авторизацию.

1 Ответ

0 голосов
/ 10 мая 2018

ColumnVisibility является частью столбца. Вам необходимо включить его, если вы собираетесь удалить запись с непустой видимостью.

Метод Mutation.putDelete имеет вариацию , которая принимает третий параметр для ColumnVisibility.

Например, заменить: 

  for (Entry<Key,Value> entry : scanner1) {
    mut.putDelete(entry.getKey().getColumnFamily(), entry.getKey().getColumnQualifier());
  }

со следующим: 

  for (Entry<Key,Value> entry : scanner1) {
    Key k = entry.getKey();
    mut.putDelete(k.getColumnFamily(), k.getColumnQualifier(), k.getColumnVisibilityParsed());
  }

ВНИМАНИЕ: будьте осторожны с этим; этот цикл сканирования и удаления удалит все данные, найденные сканером.

Примечание: putDelete перед циклом вашего сканера является избыточным; он уже будет удален, если он существует, в цикле.

...