【已解决】有木有spark对hbase进行增删改的例子呀

木有听说学习spark要果断抛java，拥抱scala吗？

撸主问题解决了，给贴出来一个java示例吧！！！
先感谢楼主啦

haorengoodman 发表于 2015-1-13 09:24
撸主问题解决了，给贴出来一个java示例吧！！！
先感谢楼主啦

对于查询的例子网上都有，添加和删除的话主要是在foreach方法进行，以下是删除一行记录的核心代码：
context.parallelize(list).foreach(new VoidFunction<String>() {

                        private static final long serialVersionUID = 1L;
                        private HTable myTable;
                        @Override
                        public void call(String delStr) throws Exception {
                                Configuration conf = HBaseConfiguration.create();
                                String[] delA = delStr.split(",");
                                String tableName = delA[0];               
                                conf.set(TableOutputFormat.OUTPUT_TABLE, tableName);
                                myTable = new HTable(conf, tableName);
                               
                                Delete del = new Delete(Bytes.toBytes(delA[1]));
                                myTable.delete(del);
                       
                                myTable.close();
                        }
                });

高帝斯法则 发表于 2015-1-13 10:19
对于查询的例子网上都有，添加和删除的话主要是在foreach方法进行，以下是删除一行记录的核心代码：
con ...

谢谢楼主，已经实现 增删改查。foreach 这个方法才是关键啊。

haorengoodman 发表于 2015-1-14 09:37
谢谢楼主，已经实现 增删改查。foreach 这个方法才是关键啊。

O(∩_∩)O

多谢各位大神， 先mark下
、

谢谢楼主分享。