distributed-computing

1зной

2ответ

Невозможно построить Storm для примера штормового стартера

Я полный новичок с штормом Apache. Я попытался следовать за штормовым стартером. Я клонировал репозиторий, а затем попытался построить и установить локальную бурю. К сожалению, я даже не могу этого сд

3зной

3ответ

Почему извлечение аргумента из искры в локальную переменную считается более безопасным?

Я видел этот пример в этой книге «Обучение Spark: молниеносный анализ больших данных»: class SearchFunctions(val query: String) { // more methods here def getMatchesNoReference(rdd: RDD[String]): RD

1зной

1ответ

Создать RDD массивов

Поскольку я живу в агонии для Is Spark's KMeans unable to handle bigdata?, я хочу создать минимальный пример, чтобы продемонстрировать драму. Для этого я хочу создать данные, а не читать их. Вот что в

2зной

1ответ

spark unix_timestamp тип данных несоответствие

Может ли кто-нибудь помочь мне в каком типе или формате данных мне нужно отправить from_unixtime для искры from_unixtime() для работы? Когда я пытаюсь выполнить это, он работает, но не отвечает curren

0зной

1ответ

Как реагировать на разные ответы на одни и те же запросы, исходя из того, было ли оно отвечено?

Предположим, у моего сервера python есть три разных ответа. И один пользователь одновременно отправляет три HTTP-запроса. Как я могу убедиться, что один запрос получит один уникальный ответ из моих тр

2зной

1ответ

Правильный способ записи двух поплавков в обычный txt

Я запускаю большую работу в режиме кластера. Тем не менее, меня интересуют только два числа с плавающей точкой, которые я хочу как-то прочитать, когда работа преуспеет. Вот что я пытаюсь: from pyspark