分享 spark1.02怎么实现读取hbase的数据
zhanggl 2015-3-31 15:32
请问spark 怎么实现读取hbase的数据并且展示出来 import org.apache.hadoop.conf.Configuration; import org.apache.hadoop.hbase.HBaseConfiguration; import org.apache.hadoop.hbase.client.Result; import org.apache.hadoop.hbase.client.Scan; import org.apache.hadoop.hbase.io.ImmutableBytesWritable; ...
个人分类: hbase|2080 次阅读|0 个评论
分享 Hbase数据导入,直接用mapreduce的方式
zhanggl 2014-8-25 22:56
第一种直接读取文件,然后用 mapreduce 的方式导入。测试数据 370 万,大小 30G 用时 284 分钟,这种方式数据丢失很严重,丢了将近60万的数据 文件大小 500M ,数据两 80000 Current count: 83000, row: f9acea1367b9bea8a16edee4035f65f7 ...
个人分类: hbase|1013 次阅读|0 个评论
分享 读取hdfs上的文件 ,并直接写入hbase数据库NoClassDefFoundError: org/apache/hadoop/ ...
zhanggl 2014-7-4 11:48
今天在导hdfs上的数据到hbase数据库时出现错误提示: Exception in thread "main" java.lang.NoClassDefFoundError: org/apache/hadoop/hbase/mapreduce/TableReducer at java.lang.ClassLoader.defineClass1(Na ...
个人分类: hbase|1947 次阅读|1 个评论 热度 1
分享 用Hbase api 实现创建数据库 异常client.HConnectionManager$HConnectionImplementati ...
zhanggl 2014-5-29 14:24
我的基础环境是cdh4.5(hadoop2.0) ,hbase是0.945 package cn.util.frame.baes.hbase; import java.io.IOException; import org.apache.hadoop.conf.Configuration; import org.apache.hadoop.hbase.HBaseConfiguration; import org.apache.hadoop.hbase.HColumnDescriptor; import org.apache.hadoop.hbase.HTableDesc ...
个人分类: hbase|1156 次阅读|2 个评论 热度 1
关闭

推荐上一条 /2 下一条