Accumulo - средство проверки прогресса BatchWriter

Question

Сценарий заключается в том, что у меня есть несколько потоков, которые в конечном итоге добавляют коллекции мутаций к конкретным BatchWriters. Я не хочу, чтобы моя программа закрывалась до того, как все мутации будут перенесены в кластер. Есть ли способ проверить прогресс BatchWriter или блокировать BatchWriter до тех пор, пока он не получит через свою коллекцию мутаций, или я вообще ничего не пропущу?

Answer 1

Пока вы вызываете close() на BatchWriters после добавления всех мутаций, все будет в порядке. Метод close() будет блокироваться на стороне клиента.