ScalaコードのJUnitテストを書く必要があります

Question

ScalaとSparkを初めて使用しています。私は、次のワードカウントプログラム用のJUnitを記述する必要があります。

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

object SparkWordCount { 

    def main(args: Array[String]) { 

    meth() 

    } 

    def meth() { 

    //Spark Config object having cluster information 
    val sparkConfig = new SparkConf() 
     .setAppName("SparkWordCount") 
     .setMaster("local") 

    val sc = new SparkContext(sparkConfig) 

    val input = sc.textFile("C:\\SparkW\\input\\inp.txt") 
    val count = input.flatMap(line ⇒ line.split(" ")) 
     .map(word ⇒ (word, 1)) 
     .reduceByKey(_ + _) 
    count.saveAsTextFile("outfile") 
    System.out.println("OK"); 

    } 

} 

私はこの使用してJUnitのためのテストを書くにはどうすればよいですか？

Answer 1

あなたがテストは完全な例えば

import org.scalatest.{FlatSpec, Matchers} 

class WordCountSpec extends FlatSpec with Matchers { 
    "wordCount" should "return an empty output for an empty input" in 
withLocalSparkContext { context => 
    val lines = context.emptyRDD[String] 
    val words = WordCount.wordCount(lines).collect() 
    words should be (Seq.empty) 
}} 

チェックこのように見ることができ、多くのScalaのスペック/テストライブラリ

のいずれかを使用することができますSpec Class

は、サンプルプログラムはそこにのためにありますスケータテストの仕様などは、検索の周りに

Answer 2

私はまた、それを共有することを考えて別のを見つけた

インポートjava.io.Fileの

インポートorg.junit。{アサート、テスト}

/** * 2017年7月7日にアッシャラニにより作成。 */ クラスSparkWordCountTest {

@Test DEF試験（）：単位= { ヴァルLINE1 =新しいファイル（ "OUTFILE /部分-00000"） ヴァルLINE2 =新しいファイル（ "C：/ユーザ/ （myharani/IdeaProjects/Practice/src/test/scala/inputs.txt "） val myString = scala.io.Source.fromFile（line1）.getLines.mkString val myString1 = scala.io.Source.fromFile（line2）。 のprintln（のmyString） のprintln（myString1） Assert.assertEquals（のmyString、myString1）

}をgetLines.mkString 210}