赞
踩
创建新的maven
删除src目录
创建spark.core工程文件
Spark 由 Scala 语言开发的,所以本课件接下来的开发所使用的语言也为 Scala,咱们当 前使用的 Spark 版本为 3.0.0,默认采用的 Scala 编译版本为 2.12,所以后续开发时。我们依 然采用这个版本。开发前请保证 IDEA 开发工具中含有 Scala 开发插件
先提前准备好scala2.12的编译
如果未采用可以看之前的流程进行:
查看框架支持
选择scala框架支持
测试环境
- <dependencies>
- <dependency>
- <groupId>org.apache.spark</groupId>
- <artifactId>spark-core_2.12</artifactId>
- <version>3.0.0</version>
- </dependency>
- <dependency>
- <groupId>org.codehaus.janino</groupId>
- <artifactId>janino</artifactId>
- <version>3.0.12</version>
- </dependency>
- </dependencies>
- def main(args: Array[String]): Unit = {
- //建立spark框架连接
- //基本配置
- val sparkConf = new SparkConf().setMaster("local").setAppName("WordCount")
- //sparkConf基础配置对象 sparkConf环境 local本地环境 应用名称:WordCount
- val sc = new SparkContext(sparkConf) //将sparkConf传入核心对象中
-
-
- //关闭spark框架连接
- sc.stop()
- }
运行查看日志信息
Copyright © 2003-2013 www.wpsshop.cn 版权所有,并保留所有权利。