7
Пример кода приведен из книги Advanced Analytics с Spark. Когда я загрузить его в искровой скорлупе (версия 1.4.1) дает следующее сообщение об ошибке, указывающей, что он не может найти StatCounter:Почему этот образец кода Spark не загружается в искровой оболочке?
import org.apache.spark.util.StatCounter
<console>:9: error: not found: type StatCounter
val stats: StatCounter = new StatCounter()
^
<console>:9: error: not found: type StatCounter
val stats: StatCounter = new StatCounter()
^
<console>:23: error: not found: type NAStatCounter
def apply(x: Double) = new NAStatCounter().add(x)
Если я просто делаю следующее искровой оболочки нет никаких проблем :
scala> import org.apache.spark.util.StatCounter
import org.apache.spark.util.StatCounter
scala> val statsCounter: StatCounter = new StatCounter()
statsCounter: org.apache.spark.util.StatCounter = (count: 0, mean: 0.000000, stdev: NaN, max: -Infinity, min: Infinity)
Проблема, похоже, связана с командой load в искровой оболочке.
Вот код:
import org.apache.spark.util.StatCounter
class NAStatCounter extends Serializable {
val stats: StatCounter = new StatCounter()
var missing: Long = 0
def add(x: Double): NAStatCounter = {
if (java.lang.Double.isNaN(x)) {
missing += 1
} else {
stats.merge(x)
}
this
}
def merge(other: NAStatCounter): NAStatCounter = {
stats.merge(other.stats)
missing += other.missing
this
}
override def toString = {
"stats: " + stats.toString + " NaN: " + missing
}
}
object NAStatCounter extends Serializable {
def apply(x: Double) = new NAStatCounter().add(x)
}
Это библиотека в классе дорожка? Можете ли вы рассказать нам о местонахождении этой библиотеки и распечатать свой путь к lib? –
Я обнаружил, что я должен полностью квалифицировать StatCounter при объявлении его, хотя я его импортировал: 'val stats: org.apache.spark.util.StatCounter = new org.apache.spark.util.StatCounter()' –
Он находится в classpath по умолчанию. Пример двух строк из искровой оболочки в среднем блоке кода показывает это. Когда я загружаю файл, возникает проблема. –