我有一个问题 . 我使用Java程序在HBase中写入数据 . 我有HTable对象,我调用以下方法(伪代码):

// creates a Put object with new data
Put put = createNewPutObject(); 
htable.put(put);
htable.flushCommits();

clearBufferOnFail设置为true:

this.htable.setAutoFlush(false, true);

代码的第一部分一遍又一遍地调用 . 我们做一些事情,创建一个Put对象,刷新htable,做更多事情,创建一个Put对象......等等 .

如果我的HTable对象失去与HBase的连接会怎样?这是内部处理的吗?或者我需要关闭我的HTable对象并打开一个新的HTable对象呢?到目前为止,我认为连接是在内部使用连接池从HTable对象处理的,所以我必须做任何事情 . 我认为捕获异常然后重试就足够了 . 由于clearBufferOnFail设置为true,因此不会写入重复数据 .

但是,有太多的连接以某种方式打开会发生吗?或者这都是处理?

谢谢你的回答:-)