0

RowDeletingIterator を使用して Accumulo テーブルのエントリを削除しようとしていますが、後でテーブルをスキャンしてもエントリが削除されません。row_idここにテーブルにエントリがあると仮定してtableName、私がやっていることは次のとおりです。

Connection connection = new ZooKeeperInstance(instance, zookeepers).getConnector(username, new PasswordToken(password));
String tableName = "tableName";
connection.tableOperations().create(tableName);
connection.tableOperations().attachIterator(tableName, new IteratorSetting(1, RowDeletingIterator.class));

// Write record with row key "row_id"
String row_id = "row_id";
Text colf = new Text("");
Text colq = new Text("data");
ColumnVisibility colv = new ColumnVisibility("");
BatchWriter writer = connection.createBatchWriter(tableName, new BatchWriterConfig()
            .setMaxMemory(memBuf)
            .setMaxLatency(timeout, TimeUnit.MILLISECONDS)
            .setMaxWriteThreads(numThreads));
Mutation mutation = new Mutation(row_id);
mutation.put(colf, colq, colv, System.nanoTime(), new Value("stuff".getBytes()));
writer.addMutation(mutation);
writer.close();

... //More work takes place

// Delete the record with row key "row_id"
BatchWriter batchWriter = connection.createBatchWriter(tableName, new BatchWriterConfig()
            .setMaxMemory(memBuf)
            .setMaxLatency(timeout, TimeUnit.MILLISECONDS)
            .setMaxWriteThreads(numThreads));
Mutation mutation = new Mutation(row_id);
mutation.put(new Text(), new Text(), new ColumnVisibility(), RowDeletingIterator.DELETE_ROW_VALUE);
batchWriter.addMutation(mutation);
batchWriter.close();
4

1 に答える 1

0

問題はSystem.nanoTime()最初のインサートの部分にあったことがわかりました。それを削除して、最初の挿入を次のようにします。

mutation.put(colf, colq, colv, new Value("stuff".getBytes()));

本来のRowDeletingIteratorように機能しました。

于 2014-03-17T21:01:54.663 に答える