wukong_to_flume.rb

# The way a wukong script is written regularly:

require 'wukong'

class WukongToFlume < Wukong::Streamer::LineStreamer

  def process(body, *args)
    # take input, do some processing
    processed = body.to_s.reverse
    yield [processed]
  end

end

Wukong::Script.new(WukongToFlume, nil).run


# Now turn it into a jRuby decorator:

require 'wukong'

# The name of your class must be the camelized file name wukong_to_flume.rb => WukongToFlume
class WukongToFlume < Wukong::Streamer::LineStreamer

  # Make sure process method handles *args; expect first to be a String containing event body
  def process(body, *args)
    # take input, do some processing
    processed = body.to_s.reverse
    # change yield to return, and make sure to return ONLY an array of strings
    # yield [processed]
    return [processed]
  end

end

# Run line needs to be commented out
# Wukong::Script.new(WukongToFlume, nil).run