2016-07-11 9 views
0

-I-Tests haben folgende Testfall:SqlContext Passing, wenn eine Methode

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

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

Welche der folgenden Methode überprüft:

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

Wenn die Tests laufen ich folgendes Problem bekommen:

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

Wie kann ich die SqlContext Instanz, die ich in der Testmethode miterstellen?

Antwort

1

Put implicit vor val sqlc:

implicit val sqlc = new SQLContext(sc)