Passing SqlContext als implizite Parameter in Funken

Question

I haben eine Funktion in einem Scala Objekt, das die folgende Signatur

def f(v1:Int)(implicit sqlContext: SQLContext) 

wenn ich diese Funktion versuchen Anruf von funken Schale hat ich es

f(1) 

wie

nennen

und ich erwarte, dass der vorhandene sqlContext implizit an es übergeben wird, aber es nicht tut. Wie kann ich es funktionieren lassen, damit der sqlContext automatisch an diese Funktion übergeben wird?

-------------- ------------------- Update

Ich versuchte sqlContext.implicits zu importieren. _ in der Funkenschale vor meiner Funktion aufrufen, aber es half nicht

Answer 1

Sie brauchen nur einen SQLContext implizit auf den gleichen Kontext hinzufügen, die Sie Ihre Funktion aufrufen:

implicit val sqlContext = new SQLContext() // just an example 
// and then 
f(1) 

Wenn Sie mit apacha Spark, können Sie diesen Import verwenden:

import sqlContext.implicits._