0
私の質問は少しノービッシュに見えるかもしれません。SparkSessionビューはグローバルに
パッケージ内に多数の.scalaファイルを含むプロジェクトがあります。
object sparkSessX{
import org.apache.spark.sql.SparkSession
import org.apache.spark.sql.functions._
val spark: SparkSession = SparkSession.builder()
.appName("My App")
.config("spark.master", "local")
.getOrCreate()
// For implicit conversions like converting RDDs to DataFrames
import spark.implicits._
}
と、そのオブジェクトを拡張したり、インポートするすべてのクラス:のようなシングルトンオブジェクトの内部で上記のコードをラップすることをお勧めし
import org.apache.spark.sql.SparkSession
import org.apache.spark.sql.functions._
val spark: SparkSession = SparkSession.builder()
.appName("My app")
.config("spark.master", "local")
.getOrCreate()
// For implicit conversions like converting RDDs to DataFrames
import spark.implicits._
:私は次のようにスパーク-SQLを使用したいですか?