library(rmr2)library(rhdfs)rmr.options(backend = "local")
df1<-data.frame(a=c(1:4),b=c(6:9))df2<-data.frame(d=c(6:9),e=c(6:9))input1 <- to.dfs(list(key=df1,val=df2))
df3<-data.frame(a=c(1:3),b=c(6:8))df4<-data.frame(d=c(1:3),e=c(1:3))input2 <- to.dfs(list(key=df3,val=df4))
reducer = function(key, left, right) { if(!class(right)=="data.frame") output.val=left else output.val=right keyval(key,left)}
output<-equijoin( left.input = input1, right.input = input2, outer = c("left"), reduce = reducer)--
post: rha...@googlegroups.com ||
unsubscribe: rhadoop+u...@googlegroups.com ||
web: https://groups.google.com/d/forum/rhadoop?hl=en-US
---
You received this message because you are subscribed to the Google Groups "RHadoop" group.
To unsubscribe from this group and stop receiving emails from it, send an email to rhadoop+u...@googlegroups.com.
For more options, visit https://groups.google.com/d/optout.