Как настроить функцию для Iterable Array?

1974,1974-06-22 1966,1966-07-20 1954,1954-06-19 1994,1994-06-27 1954,1954-06-26 2006,2006-07-04 2010,2010-07-07 1990,1990-06-30 ...

It is type RDD[String].

What is wrong in the function iteself?
Структурированный массив Numpy
Структурированный массив Numpy
Однако в реальных проектах я чаще всего имею дело со списками, состоящими из нескольких типов данных. Как мы можем использовать массивы numpy, чтобы...
T - 1Bits: Генерация последовательного массива
T - 1Bits: Генерация последовательного массива
По мере того, как мы пишем все больше кода, мы привыкаем к определенным способам действий. То тут, то там мы находим код, который заставляет нас...
Что такое деструктуризация массива в JavaScript?
Что такое деструктуризация массива в JavaScript?
Деструктуризация позволяет распаковывать значения из массивов и добавлять их в отдельные переменные.
0
0
32
1
Перейти к ответу Данный вопрос помечен как решенный

Ответы 1

Ответ принят как подходящий

Пытаться

def f(v: Iterable[Array[String]]): Int = {
  val parsedDates = v.flatten.map(e => LocalDate.parse(e, formatter))
  parsedDates.max.getDayOfYear - parsedDates.min.getDayOfYear
}

который выводит

val arrays = Iterable(Array("2014-10-10","2014-12-10"))
f(arrays) // res0: Int = 61

Ошибка: org.apache.spark.SparkException: задача не сериализуема

Lazar Gugleta 20.06.2019 11:05

Попробуйте stackoverflow.com/questions/22592811/…

Mario Galic 20.06.2019 11:06

Другие вопросы по теме