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

Reply via email to