Spark读取Mysql，Redis，Hbase数据（一）

内容导读

互联网集市收集整理的这篇技术教程文章主要介绍了Spark读取Mysql，Redis，Hbase数据（一），小编现在分享给大家，供广大互联网技能从业者学习和参考。文章包含774字，纯文字阅读大概需要2分钟。

内容图文

= { Class.forName("com.mysql.jdbc.Driver").newInstance() DriverManager.getConnection("jdbc:mysql://hadoop000:3306/hive", "root", "root") } def main(args: Array[String]): Unit = { val sparkConf = new SparkConf().setAppName("jdbcRdd").setMaster("local[*]") val sc = new SparkContext(sparkConf) val jdbcRDD = new JdbcRDD( sc, getConn, "select * from TBLS where TBL_ID >= ? and TBL_ID <= ?", 1, 10, 2, rs => { val id = rs.getInt(1) val name = rs.getString(2) val age = rs.getInt(3) (id,name,age) } ) jdbcRDD.collect().toBuffer } }

 

Spark读取Mysql，Redis，Hbase数据（一）

标签：数据   tap   hbase   ase   demo   class   rman   dde   sele   

本文系统来源：https://www.cnblogs.com/hgc-bky/p/12863544.html

内容总结

以上是互联网集市为您收集整理的Spark读取Mysql，Redis，Hbase数据（一）全部内容，希望文章能够帮你解决Spark读取Mysql，Redis，Hbase数据（一）所遇到的程序开发问题。 如果觉得互联网集市技术教程内容还不错，欢迎将互联网集市网站推荐给程序员好友。

内容备注

版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 gblab@vip.qq.com 举报，一经查实，本站将立刻删除。

内容手机端

---