SparkContextをJavaSparkContextに

Sparkcontext Into Javasparkcontext

Spark2.0の自動リリース以降、

final SparkConf conf = new SparkConf().setMaster('local').setAppName('---') final JavaSparkContext ctx = new JavaSparkContext(conf)

これはフォームに変換されます

SparkSession spark = SparkSession .builder() .master('local') .appName('---') .getOrCreate()

• しかし、Javaプログラマーにはいくつか質問があります。

JavaRDD text = JavaSparkContext.fromSparkContext(spark.sparkContext()) .textFile('path')

use JavaSparkContext of fromSparkContext元のメソッドcontextデータ型を変換できます。

例

|_+_|