gistfile1.txt

job ($, _) ->
  $.flow 'word count', ->
    $.source 'input', $.tap("test.txt", $.text_line_scheme("line"))

    assembly = $.assembly 'input', ->
      $.map add: { word: "string" }, remove: ["line"], (tuple, writer) ->
        for word in tuple.line.match(/\S+/g)
          writer word: word

      count = 0

      $.foreach_group ["word"], add: { count: "int" },
        (tuple) -> count = 0,
        (tuple, writer) -> count += 1,
        (tuple, writer) -> writer count: count

    $.sink 'input', $.tap("output", $.text_line_scheme("word", "count"))