You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
Hello, We trying rmr2 package from RHADOOP - get outofmemory exception
Below is sample code - aggregate sales quarterly.
What is signature of map,reduce & keyval function?
Some documents says
"key must be a matrix with a column and the same number of rows as the value." kindly explain
Hello, We trying rmr2 package from RHADOOP - get outofmemory exception
Below is sample code - aggregate sales quarterly.
What is signature of map,reduce & keyval function?
Some documents says
"key must be a matrix with a column and the same number of rows as the value." kindly explain
thanks
`
sample input data
time, sales
1,206
2,245
3,185
4,169
5,162
6,177
7,207
8,216
9,193
10,230
11,212
12,192
library(rmr2)
map <- function(key,value)
{
print("sales are ")
print(value)
salesLine <- unlist(strsplit(value, "[,]"))
month <- salesLine[1]
sales <- salesLine[2]
if (month >=1 && month <= 4)
month <- 4
else if (month >=5 && month <= 8)
month <- 8
else month <- 12
return(keyval(month,sales))
}
reduce <- function(key,values)
{
keyval(key, sum(values))
}
forecast <- function(input,output=NULL)
{
mapreduce(input=input,input.format="text",map=map,output=output)
}
hdfs.root <- "forecast"
hdfs.data <- file.path(hdfs.root,"input")
hdfs.out <- file.path(hdfs.root,"output")
out <- forecast(hdfs.data,hdfs.out)
`
The text was updated successfully, but these errors were encountered: