我希望数据能够实时入库,现在是用线程定时去抓文件入库到Hbase。
但是,现在有两个入库方式。
1---使用官方已经废弃的方法。每次入库到Hbase(是用的put(list)方法),每次都要关闭掉table,再重新连接hbase,Htable table开销非常大。使用后如果只调用table.flushCommits()接口,资源并没有释放,内存一直涨.....
请问有没有比较好的建议?
2---使用新的API。用ConnectionFactory.createConnection获取连接,然后通过连接获取table,这时候table释放资源只提供了close方法。我尝试table.close();connection.close(),资源仍然未释放,内存一直涨。