flink-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Aljoscha Krettek <aljos...@apache.org>
Subject A small Project I've been working on
Date Wed, 01 Apr 2015 06:43:31 GMT
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

Mime
View raw message