Hi, I've been working on a little side project in my free time: Ruby on Flink (RoF). This should finally allow us to tap into the whole web developer ruby world. The design is also flexible enough to easily port this to node.js.
The code is not yet in shape to be made public but this is a small preview of what the API looks like: input = env.read_text_file("/some/path") words = input.flatMap do |line| parts = line.split(/\W+/) parts.each do |word| word, 1 end end counts = words.reduce do |left, right| left(1), left(1) + right(2) end counts.print() env.execute!() Cheers, Aljoscha