У меня есть "данные" DataFrame в sparkR, которые содержат ID = 1,2,.. и количество = 232, 303, 444, 10,... Я хочу проверить, превышает ли сумма суммы 5000.
sum(data$amount ) > 5000
Теперь sparkR должен возвращать TRUE, если это TRUE и FALSE в противном случае, но все, что я получаю, это это сообщение
Column (SUM(amount)>5000)
Как я могу проверить, правда ли это?
Возможно, это не лучшее решение, но оно работает. Вы создали столбец из 1 элемента, но я не нашел способа получить результат, хранящийся в этом элементе, поэтому я применил другой подход:
df <- data.frame(ID=c(1,2,3,4),amount=c(232, 303, 444, 10))
data <- createDataFrame(sqlContext,df)
data <- withColumn(data, "constant", data$ID * 0)
sumFrame <- agg(groupBy(data, data$constant), sumAmount = sum(data$amount))
localResult <- collect(sumFrame)
localResult$sumAmount > 5000
При таком подходе я создаю DataFrame из 1 строки, но для получения результата можно собрать DataFrame.
