Wert saveToCassandra ist kein Mitglied von org.apache.spark.streaming.dstream.DStream [(String, Int)]

Question

Ich bin neu in Spark, ich bekomme diesen Fehler, wenn ich versuche, Daten in Cassandra zu speichern. Ich habe importiert: StreamingContext._ und SparkContext._, aber immer noch den Fehler.

Dies sind die Abhängigkeiten Ich verwende:

"org.apache.spark" %% "spark-core" % "1.5.2", 
"org.apache.spark" %% "spark-streaming" % "1.5.2", 
"com.datastax.spark" %% "spark-cassandra-connector" % "1.5.0", 
"org.apache.spark" %% "spark-sql" % "1.5.2" 

Danke

Answer 1

zu können saveToCassandra verwenden, um auf einem DStream Sie haben DStreamFunctions zum Beispiel importieren mit:

import com.datastax.spark.connector.streaming._