我有这段代码可以保存到HBaseHTABLE。预期的行为是该表将为每个分区推送提交或将puts“刷新”到hbase。注意:这是更新后的代码rdd.foreachPartition(p=>{valtable=connection.getTable(TableName.valueOf(HTABLE))valmutator=connection.getBufferedMutator(TableName.valueOf(HTABLE))p.foreach(row=>{valhRow=newPut(rowkey)hRow.addColumn....//usetable.existsinstead