Contents

#!/usr/bin/env ruby
Dir[File.dirname(__FILE__)+'/vendor/**/lib'].each{|dir| $: << dir }
require 'rubygems'
require 'wukong'

class FooStreamer < Wukong::Streamer::LineStreamer
  def initialize *args
    super *args
    @line_no = 0
  end

  def process *args
    yield ["%5d" % @line_no, *args]
    @line_no += 1
  end
end

Wukong::Script.new(FooStreamer, FooStreamer).run

Version data entries

2 entries across 2 versions & 1 rubygems

Version	Path
wukong-1.5.2	examples/emr/elastic_mapreduce_example.rb
wukong-1.5.1	examples/emr/elastic_mapreduce_example.rb