我想启动一个嵌入到我的Java应用程序中的独立Apache Spark集群的实例。我试图在他们的网站上找到一些文档,但还没有找到。

这可能吗?

最佳答案

您可以在本地模式下创建SparkContext,只需向SparkConf提供“本地”作为Spark主网址。

val sparkConf = new SparkConf().
  setMaster("local[2]").
  setAppName("MySparkApp")

val sc = new SparkContext(sparkConf)

09-11 04:46