Spark работа с асинхронным HTTP-вызовом

Я строю RDD из списка URL-адресов, а затем пытаюсь получить данные с помощью асинхронного http-вызова. Мне нужны все результаты, прежде чем делать другие рас...

Как получить вероятности классификации из MultilayerPerceptronClassifier?

Конвертировать список Java в Scala Seq

Суммарные значения PairRDD

У меня есть RDD типа:

В scala есть ли способ проверить, является ли экземпляр одноэлементным объектом или нет?

Если у меня есть экземпляр объекта, есть ли способ проверить, есть ли у меня одноэлементный объект, а не экземпляр класса? Есть ли способ сделать это? Может ...

Исключение Apache Spark в потоке «main» java.lang.NoClassDefFoundError: scala / collection / GenTraversableOnce $ class

Версия Scala: 2.11.7 (пришлось обновить версию scala, чтобы разрешить регистру принимать более 22 параметров.) Версия Spark: 1.6.1 PFB pom.xmlОшибка ниже при...

Spark Streaming mapWithState, кажется, периодически перестраивает завершенное состояние

Я работаю над потоковым проектом Scala (2.11) / Spark (1.6.1) и использую

Выход из Spark-shell из скрипта scala

Спарк Роу в JSON

Я хотел бы создать JSON из фрейма данных Spark v.1.6 (используя scala). Я знаю, что есть простое решение

Почему перенос обобщенного вызова метода с помощью Option откладывает ClassCastException?

Допустим, у меня есть такой массив *: