用于我们操作的时候就行回调 */ public interface HBaseInvok { /** * 回调方法 */ public void invok(); } (3)HBaseStorage articleQuantitList.isEmpty()) { List<HBaseStorage> hbaseStorageList = articleQuantitList.stream = articleQuantity) { HBaseStorage hBaseStorage = articleQuantity.getHbaseStorage(); hBaseStorageClient.addHBaseStorage(HBaseConstants.APARTICLE_QUANTITY_TABLE_NAME, hBaseStorage);
4.7 HbaseStorage 加载和存储数据来自Hbase表 用法同PigStorage类似,需要指定分割符,和加载选项HbaseStorage(’columns’,’option’) 4.8