Also, I tried that code and I keep getting this error:
<console>:26: error: overloaded method value max with alternatives:
(x$1: Double,x$2: Double)Double <and>
(x$1: Float,x$2: Float)Float <and>
(x$1: Long,x$2: Long)Long <and>
(x$1: Int,x$2: Int)Int
cannot be applied to (String, Int.type)
nums.foreachRDD(rdd => {globalMax = Math.max(rdd.max,
globalMax)
What might be causing this?
--
View this message in context:
http://apache-spark-user-list.1001560.n3.nabble.com/Use-SparkStreaming-to-find-the-max-of-a-dataset-tp11734p11799.html
Sent from the Apache Spark User List mailing list archive at Nabble.com.
---------------------------------------------------------------------
To unsubscribe, e-mail: user-unsubscr...@spark.apache.org
For additional commands, e-mail: user-h...@spark.apache.org
