值saveToCassandra不是org.apache.spark.streaming.dstream.DStream的成員[（String，Int）]

Question

我是Spark新手，當我嘗試將數據保存到cassandra時出現此錯誤。 我已導入：StreamingContext._和SparkContext._，但仍然出現錯誤。

這是我使用的依賴關係：

"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" 

謝謝

Answer 1

爲了能夠在DStream你必須輸入DStreamFunctions例如與使用saveToCassandra：

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