Accumulo-检查BatchWriter进度的方法



场景是,我有几个线程,它们最终将突变集合添加到特定的BatchWriters中。我不希望我的程序在所有突变被推送到集群之前关闭。有没有办法检查BatchWriter的进度,或者BatchWriter是否在完成突变集合之前一直处于停滞状态,或者我是否完全遗漏了什么?

只要在添加所有突变后对BatchWriters调用close(),就可以了。close()方法将在客户端进行阻塞。

相关内容

  • 没有找到相关文章

最新更新