#2615 Writing Hadoop MapReduce in Fantom

go4 Sat 8 Jul

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

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

It's used for log analysis and data mining.

Login or Signup to reply.