在windows下配置eclipse的spark调试环境
2016-01-05 23:55
507 查看
1.下载配置jdk,scala。
2.下载eclipse for scala。
3.下载带编译好的spark jar包。
4.在eclipse中新建工程,导入 spark-assembly-1.1.1-hadoop1.0.4.jar 这类jar包,并且删除scala原有的library。
5.新建类,输入以下代码,执行成功就可以了
import
scala.math.random
import
org.apache.spark._
/** Computes an approximation to pi */
object
test2
{
def
main(args
: Array[String])
{
val
conf
=
new
SparkConf().setAppName(
"Spark Pi").setMaster
("local"
)
val
spark
=
new
SparkContext(conf)
val
slices
=
if
(args
.length
>
0
)
args
(0
).toInt
else
2
val
n
= math.
min(100000L
*
slices
,
Int
.MaxValue
).toInt
// avoid overflow
val
count
=
spark
.parallelize
(1
until
n
,
slices
).map
{
i
=>
val
x
=
random
*
2
-
1
val
y
=
random
*
2
-
1
if
(
x*x
+
y
*y
<
1)
1
else
0
}.reduce(_
+
_)
println("Pi
is roughly "
+
4.0
*
count
/
n
)
spark.stop()
}
}
其中最重要的是黄底的位置,必须设置为local,在使用ide本地调试的时候,不管是eclipse还是IntelliJ都是配置上面的conf
2.下载eclipse for scala。
3.下载带编译好的spark jar包。
4.在eclipse中新建工程,导入 spark-assembly-1.1.1-hadoop1.0.4.jar 这类jar包,并且删除scala原有的library。
5.新建类,输入以下代码,执行成功就可以了
import
scala.math.random
import
org.apache.spark._
/** Computes an approximation to pi */
object
test2
{
def
main(args
: Array[String])
{
val
conf
=
new
SparkConf().setAppName(
"Spark Pi").setMaster
("local"
)
val
spark
=
new
SparkContext(conf)
val
slices
=
if
(args
.length
>
0
)
args
(0
).toInt
else
2
val
n
= math.
min(100000L
*
slices
,
Int
.MaxValue
).toInt
// avoid overflow
val
count
=
spark
.parallelize
(1
until
n
,
slices
).map
{
i
=>
val
x
=
random
*
2
-
1
val
y
=
random
*
2
-
1
if
(
x*x
+
y
*y
<
1)
1
else
0
}.reduce(_
+
_)
println("Pi
is roughly "
+
4.0
*
count
/
n
)
spark.stop()
}
}
其中最重要的是黄底的位置,必须设置为local,在使用ide本地调试的时候,不管是eclipse还是IntelliJ都是配置上面的conf
相关文章推荐
- Java的反射机制
- Java泛型初探
- Java延迟初始化的2种经典模式
- 一则spring容器启动死锁问题(DefaultListableBeanFactory/DefaultSingletonBeanRegistry)
- java基础
- [译]GC专家系列2:Java 垃圾回收的监控
- HDFS中JAVA API的使用
- 使用Spring Security实现权限管理
- 简析线程
- 给jdk写注释系列之jdk1.6容器(10)-Stack&Vector源码解析
- Eclpise_设置Eclipse中的tab键为4个空格
- java中的GregorianCalendar类
- 2016-1-5-Thinking in Java 读书笔记(二) --一切都是对象
- java语言编程汇总
- Java 连接 MySQL
- [转]Spring数据库读写分离
- 使用Spring Boot来加速Java web项目的开发
- Java内存模型(转载)
- 自学java hibernate简单使用
- java 将list按指定大小等分,最后多余的单独一份