sparkr

1зной

1ответ

SparkContext в SparkR (v1.5.1) является Java ref type org.apache.spark.api.java.JavaSparkContext однако при создании моего класса: .jnew("com.example.MyClass","sc") для моего класса лестницы: клас

2зной

1ответ

Почему функции окна (Lag) не работают в SparkR?

Я довольно новичок в Spark и SparkR в этом вопросе, и у меня могут возникнуть некоторые основные вопросы. Целью этого упражнения было реализовать функции окна (свинец, лаг, ранг и т. Д.) В SparkR. я г

2зной

1ответ

Запуск корреляций в SparkR: нет метода для принудительного применения этого класса S4 к вектору

Я недавно начал использовать SparkR и хотел бы запустить с ним корреляционный анализ . Я могу загружать контент в виде SparkR dataframe, но он не позволяет запускать простой анализ cor() с фреймом дан

2зной

2ответ

SparkR на Windows - Спарк SQL не имеет встроенной поддержки улей

Я пытаюсь использовать искру в моей, локальной машине, и я был в состоянии воспроизвести учебник по адресу: http://blog.sparkiq-labs.com/2015/07/26/installing-and-starting-sparkr-locally-on-windows-os

0зной

2ответ

Как фильтровать SparkR DataFrame

В SparkR У меня есть DataFrame data, который содержит user, act и time для каждого действия. act содержит числа от 1 до 9, то есть мы имеем 9 актов. head(data) затем дает user act time 21 1 2012-0

0зной

1ответ

sparkR, как использовать функцию sql()?

Недавно я начал использовать SparkR. Я использую сервер Rstudio. , но когда я бегу sql_tmp3 <- sql(sqlContext, "FOR i IN 1..3 LOOP INSERT INTO tmptable VALUES (i) END LOOP") Я получаю

-2зной

2ответ

R - обработка данных и масштабируемый код

Hy, В последние дни у меня была небольшая проблема. У меня есть набор данных транзакций с 1 миллионом строк и двумя столбцами (идентификатор клиента и идентификатор продукта), и я хочу преобразовать э

5зной

2ответ

Дублирующие столбцы в Spark Dataframe

У меня есть файл csv размером 10 ГБ в кластере с плавающей точкой с дублирующимися столбцами. Я пытаюсь анализировать ее в SparkR поэтому я использую spark-csv пакет, чтобы разобрать его как DataFrame