为了账号安全,请及时绑定邮箱和手机立即绑定

spark1.2.1实现读取hbase的数据后怎么实现实时查询?

spark1.2.1实现读取hbase的数据后怎么实现实时查询?

慕码人8056858 2018-12-19 18:14:46
spark1.2.1实现读取hbase的数据后怎么实现实时查询
查看完整描述

1 回答

?
莫回无

TA贡献1865条经验 获得超7个赞

 调用parallelize函数直接从集合中获取数据,并存入RDD中;Java版本如下:
  1 JavaRDD<Integer> myRDD = sc.parallelize(Arrays.asList(1,2,3));
  Scala版本如下:
  1 val myRDD= sc.parallelize(List(1,2,3))
  这种方式很简单,很容易就可以将一个集合中的数据变成RDD的初始化值;更常见的是(2)、从文本中读取数据到RDD中,这个文本可以是纯文本文件、可以是sequence文件;可以存放在本地(file://)、可以存放在HDFS(hdfs://)上,还可以存放在S3上。其实对文件来说,Spark支持Hadoop所支持的所有文件类型和文件存放位置。

查看完整回答
反对 回复 2019-01-05
  • 1 回答
  • 0 关注
  • 939 浏览

添加回答

举报

0/150
提交
取消
意见反馈 帮助中心 APP下载
官方微信