queueStream.saveToInflux() - Error

pygmalios / reactiveinflux-spark

Connector between Spark and InfluxDB.

Apache License 2.0

24 stars 7 forks source link

Closed thimmy687 closed 6 years ago

thimmy687 commented 6 years ago

Hello,

I tried to implement your example, but I still get the error:

value saveToInflux is not a member of org.apache.spark.streaming.dstream.DStream[com.pygmalios.reactiveinflux.Point]

Do you have some experiences with this issue and how I could solve it?

I use Scala 2.11

Best Regards

thimmy687 commented 6 years ago

Hi guys,

I could solvve the problem :)

I also have a connection to a Cassandra database, it wanted to access its DStream extension.