2017-01-17 24 views
1

我创建了一个简单的Scala代码:如何运行的主要方法从火花(在Databricks)

import org.apache.spark.SparkContext 
import org.apache.spark.SparkContext._ 
import org.apache.spark.SparkConf 

object app2 { 
    def main(args: Array[String]) { 
    val conf = new SparkConf().setAppName("Simple Application") 
    val sc = new SparkContext(conf) 
    println(s"This is a simple scala code v2 - it is running a Spark code.") 
    sc.stop() 
    } 
} 

然后用SBT编制了创建JAR文件。

然后补充说,JAR星火笔记本:

sc.addJar("some/path") 

如何运行(调用)Databricks笔记本这里面主要方法(应用)才能看到“的println”命令的输出?

+0

(https://docs.cloud.databricks.com/docs/latest/databricks_guide/01%20Databricks%20Overview/06%20Jobs .html) –

回答

1

非常感谢'Ronak'。看来这是一个阶代码的获胜组合:[?遵循这个]

/* app4.scala */ 
import org.apache.spark.SparkContext 
import org.apache.spark.SparkContext._ 
import org.apache.spark.SparkConf 

object app4 { 
    def main(args: Array[String]) { 
    val goodSparkContext = SparkContext.getOrCreate() 
    println(s"This is a simple scala code v4 - it is running a Spark code.") 
    } 
} 
+0

这是如何回答OP的问题? – Paul