九年级上册英语视频,清除甲醛,帷千动媒
1、读取mysql数据
object jdbcrdddemo { def getconn() = { 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 } }
转自:https://www.cnblogs.com/hgc-bky/p/12863544.html
如对本文有疑问,请在下面进行留言讨论,广大热心网友会与你互动!! 点击进行留言回复
去 HBase,Kylin on Parquet 性能表现如何?
如何找到Hive提交的SQL相对应的Yarn程序的applicationId
如何在 HBase Shell 命令行正常查看十六进制编码的中文?哈哈~
HBase Filter 过滤器之 Comparator 原理及源码学习
安装 Hadoop 2.9.1 on Windows 10 64 bit (最全步骤整理)
网友评论