我想启动一个嵌入到我的Java应用程序中的独立Apache Spark集群的实例。我试图在他们的网站上找到一些文档,但还没有找到。
这可能吗?
最佳答案
您可以在本地模式下创建SparkContext,只需向SparkConf提供“本地”作为Spark主网址。
val sparkConf = new SparkConf().
setMaster("local[2]").
setAppName("MySparkApp")
val sc = new SparkContext(sparkConf)