方法

2016-07-11 3 views
0

をテストするとき、私は、次のテストケースがあります。方法

test("check foo") { 
    val conf = new SparkConf() 
    val sc = new SparkContext(conf) 
    val sqlc = new SQLContext(sc) 

    val res = foo("A", "B") 
    assert(true) 
    } 

次のメソッドチェック:私は次の問題を取得するテストを実行している場合

def foo(arg1: String, arg2: String) (implicit sqlContext: SQLContext) : Seq[String] = { 
    //some other code 
    } 

を:

Error:(65, 42) could not find implicit value for parameter sqlContext: org.apache.spark.sql.SQLContext 
val res = foo("A", "B") 

でテストメソッドで作成したSqlContextインスタンスを共有するにはどうすればいいですか??

答えて

1

val sqlcの前でimplicitを入れて:

implicit val sqlc = new SQLContext(sc)