基于spark1.3.1的spark-sql实战是怎么样的
基于spark1.3.1的spark-sql实战是怎么样的,很多新手对此不是很清楚,为了帮助大家解决这个难题,下面小编将为大家详细讲解,有这方面需求的人可以来学习下,希望你能有所收获。
成都创新互联公司专注于成都网站制作、成都网站设计、网页设计、网站制作、网站开发。公司秉持“客户至上,用心服务”的宗旨,从客户的利益和观点出发,让客户在网络营销中找到自己的驻足之地。尊重和关怀每一位客户,用严谨的态度对待客户,用专业的服务创造价值,成为客户值得信赖的朋友,为客户解除后顾之忧。
将HIVE_HOME/conf/hive-site.xml
文件copy到SPARK_HOME/conf/下
未由配置单元站点配置时。xml,上下文自动在当前目录中创建metastore_db和warehouse。
// sc is an existing SparkContext.val sqlContext = new org.apache.spark.sql.hive.HiveContext(sc)sqlContext.sql("CREATE TABLE IF NOT EXISTS src (key INT, value STRING)")sqlContext.sql("LOAD DATA LOCAL INPATH 'examples/src/main/resources/kv1.txt' INTO TABLE src")// Queries are expressed in HiveQLsqlContext.sql("FROM src SELECT key, value").collect().foreach(println)
JDBC To Other Databases
加载MySQL数据库:test,表:t_user_new返回DataFrame
查询数据:
Performance Tuning
spark 程序操作JDBC:
看完上述内容是否对您有帮助呢?如果还想对相关知识有进一步的了解或阅读更多相关文章,请关注创新互联行业资讯频道,感谢您对创新互联的支持。
新闻标题:基于spark1.3.1的spark-sql实战是怎么样的
网页路径:http://scyanting.com/article/posjdo.html