Вот рабочий пример использования Either: val a: Either[Int, String] = { if (true) Left(42) //...

Я внедрил аккумуляторы, чтобы увидеть количество событий в моем коде. Но я не вижу их в интерфейсе...

Я не могу заставить команду spark-shell работать на Git bash. Я уверен, что моя среда настроена...

У меня есть фрейм данных следующим образом: import org.apache.spark.sql.expressions.Window import...

Следующий метод выдает ошибку, даже не вызывая ее. type Checklist = (Int,String,Boolean) def...

Как я могу сделать string.replace ("fromstr", "tostr") на фрейме данных Scala. Насколько я вижу,...

Я хочу установить системное свойство JVM line.separator для одной новой строки в Windows (по...

Я делаю упражнения из приложения Структуры данных в Scala. Я кодировал вторую проблему для массивов...

У меня был бы простой вопрос ... Я пытаюсь использовать функцию, которая съела фрейм данных в...

У меня есть некоторая дата в формате java.sql.Date, и я хочу сравнить их import java.sql.Date...

Я формирую матрицу распределенных блоков из матрицы индексированных строк, контролируя размер...

У меня есть конкретный случай в foldLeft scala> val nums = List(1, 1, 0, 1, 0, 0, 1, 0, 0, 1, 0,...

Я сейчас ссылаюсь на Spark в книге действий, в которой я сталкивался с использованием одного и того...

У меня есть файл Avro, содержащий десятичный логический тип, как показано ниже:...

У меня есть схема данных, как показано ниже: я не могу выровнять ее в правильном формате.Мне нужна...

Я хочу создать матрицу индексированных строк в Scala - Spark, которая имеет случайные значения в...

Вот мой код. Я получил ошибку компиляции во втором предложении case: Ошибка: (92, 26) значение

Я надеюсь, что вы мне поможете: -) У меня есть датафрейм с опубликованным объявлением.Я хочу, чтобы...

Я использую оператор ++:, чтобы получить коллекцию из двух коллекций, но результаты, которые я...

Может кто-нибудь, пожалуйста, помогите мне здесь, Как решить Я пытаюсь удалить строки из моей...

Я использую Spark со Scala.Я бы хотел, чтобы Spark сохранял кадры данных с вычисленными значениями,...

У меня есть каталог на моем локальном компьютере, путь которого - / b / yyyymmdd. 'yyyymmdd' - это...

У меня есть DataFrame, где несколько столбцов содержат значения типа Array [String] (до X столбцов)

Я использую макросы Scala и сопоставляю Apply, и я хотел бы получить полное имя вызываемой функции....

Предположим, у меня есть фрейм данных Spark с именем trades, который имеет в своей схеме несколько...