Ich habe versucht, mein Couchbase Server EMR Spark-1.4.1, zu verbinden, während die EMRSpark erorr: Wert Couchbase ist kein Mitglied von org.apache.spark.sql.DataFrameReader
angetroffenval airlines = sqlContext.read.couchbase(schemaFilter = org.apache.spark.sql.sources.EqualTo("type", "airline"))
<console>:24: error: value couchbase is not a member of org.apache.spark.sql.DataFrameReader
sind alle, Befehle erfolgreich vor diesem Fehler Befehl ausgeführt:
funken shell --packages com.couchbase.client: spark-connector_2.10. 1.0.0
import org.apache.spark {SparkContext, SparkC ONF}
- val sc = new SparkContext (new SparkConf(). setAppName ("Test"). Set ("com.couchbase.bucket.travel-Probe", ""))
- val CFG = new SparkConf() .setAppName ("keyValueExample"). setMaster ("local [*]"). set ("com.couchbase.bucket.travel-Beispiel", "")
- import org.apache.spark.sql.SQLContext
- val sql = new SqlContext (sc)
- Import com.couchbase.spark._
muss ich etwas mehr konfigurieren? Da ich AWS EMR verwende, habe ich angenommen, dass ich die .sbt-Datei nicht ändern muss? Ich glaube, ich habe das Paket bereits entweder beim Angeben der Verbindung zu Spark-Shell oder in Zeile (Befehl) 7 importiert?