A lib to generate mapreduce job in high-level API.
Word count example:
Void main() { init ds := c.load(input).map{ it.split(' ').join("\n") }.reduce(0)|Int r,v|{ r + 1 } ds.save(output) }
Learn more
That's interesting! I see you can optionally fork out to Hadoop or external processes; what do you use it for?
It's used for log analysis and data mining.
Login or Signup to reply.
go4 Sat 8 Jul 2017
A lib to generate mapreduce job in high-level API.
Word count example:
Void main() { init ds := c.load(input).map{ it.split(' ').join("\n") }.reduce(0)|Int r,v|{ r + 1 } ds.save(output) }Learn more
SlimerDude Sat 8 Jul 2017
That's interesting! I see you can optionally fork out to Hadoop or external processes; what do you use it for?
go4 Sun 9 Jul 2017
It's used for log analysis and data mining.